From 15c18f6f3fd1045bac3b582310eb3573ad810957 Mon Sep 17 00:00:00 2001 From: Nowaker Date: Fri, 22 Jan 2016 22:42:53 -0600 Subject: [PATCH] Pass exception object to sidekiq_retries_exhausted block --- lib/sidekiq/middleware/server/retry_jobs.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/sidekiq/middleware/server/retry_jobs.rb b/lib/sidekiq/middleware/server/retry_jobs.rb index 9a9bfcb9..10774d86 100644 --- a/lib/sidekiq/middleware/server/retry_jobs.rb +++ b/lib/sidekiq/middleware/server/retry_jobs.rb @@ -130,17 +130,17 @@ module Sidekiq end else # Goodbye dear message, you (re)tried your best I'm sure. - retries_exhausted(worker, msg) + retries_exhausted(worker, msg, exception) end raise exception end - def retries_exhausted(worker, msg) + def retries_exhausted(worker, msg, exception) logger.debug { "Dropping message after hitting the retry maximum: #{msg}" } begin if worker.sidekiq_retries_exhausted_block? - worker.sidekiq_retries_exhausted_block.call(msg) + worker.sidekiq_retries_exhausted_block.call(msg, exception) end rescue => e handle_exception(e, { context: "Error calling retries_exhausted for #{worker.class}", job: msg })