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