lib/sidekiq/job_retry.rb in sidekiq-6.5.0 vs lib/sidekiq/job_retry.rb in sidekiq-6.5.1
- old
+ new
@@ -174,11 +174,11 @@
delay = delay_for(jobinst, count, exception)
# Logging here can break retries if the logging device raises ENOSPC #3979
# logger.debug { "Failure! Retry #{count} in #{delay} seconds" }
retry_at = Time.now.to_f + delay
payload = Sidekiq.dump_json(msg)
- Sidekiq.redis do |conn|
+ redis do |conn|
conn.zadd("retry", retry_at.to_s, payload)
end
else
# Goodbye dear message, you (re)tried your best I'm sure.
retries_exhausted(jobinst, msg, exception)
@@ -193,10 +193,10 @@
handle_exception(e, {context: "Error calling retries_exhausted", job: msg})
end
send_to_morgue(msg) unless msg["dead"] == false
- Sidekiq.death_handlers.each do |handler|
+ config.death_handlers.each do |handler|
handler.call(msg, exception)
rescue => e
handle_exception(e, {context: "Error calling death handler", job: msg})
end
end