Class: Sidekiq::SetCurrentRetry
- Inherits:
-
Object
- Object
- Sidekiq::SetCurrentRetry
- Defined in:
- lib/sidekiq/set_current_retry.rb
Instance Method Summary collapse
Instance Method Details
#call(worker, job, _queue) ⇒ Object
5 6 7 8 9 10 11 12 |
# File 'lib/sidekiq/set_current_retry.rb', line 5 def call(worker, job, _queue) if worker.respond_to?(:current_retry=) # value of job['retry_count'] follows the progression: nil, 0, 1, 2, 3, ... worker.current_retry = job['retry_count'].present? ? (job['retry_count'].to_i + 1) : nil end yield end |