class Sidekiq::Rescue::ServerMiddleware
def reschedule_job(job_payload:, delay:, rescue_counter:, error_group:, queue:)
def reschedule_job(job_payload:, delay:, rescue_counter:, error_group:, queue:) payload = job_payload.dup payload["at"] = Time.now.to_f + delay if delay.positive? payload["sidekiq_rescue_exceptions_counter"] = { error_group.to_s => rescue_counter } payload["queue"] = queue Sidekiq::Client.push(payload) end