module Rage::Deferred::Task::ClassMethods
def __next_retry_in(attempts)
- Private: -
def __next_retry_in(attempts) rand(BACKOFF_INTERVAL * 2**attempts.to_i) + 1 end
def __should_retry?(attempts)
- Private: -
def __should_retry?(attempts) attempts < MAX_ATTEMPTS end
def enqueue(*args, delay: nil, delay_until: nil, **kwargs)
def enqueue(*args, delay: nil, delay_until: nil, **kwargs) context = Rage::Deferred::Context.build(self, args, kwargs) Rage::Telemetry.tracer.span_deferred_task_enqueue(task_class: self, context:) do Rage::Deferred.__middleware_chain.with_enqueue_middleware(context, delay:, delay_until:) do Rage::Deferred.__queue.enqueue(context, delay:, delay_until:) end end nil end