diff --git a/lib/sidekiq/logging/shared.rb b/lib/sidekiq/logging/shared.rb index 06990a7..67b1db9 100644 --- a/lib/sidekiq/logging/shared.rb +++ b/lib/sidekiq/logging/shared.rb @@ -38,6 +38,11 @@ def log_job(payload, started_at, exc = nil) # Needs to map all args to strings for ElasticSearch compatibility payload['args'].map!(&:to_s) + if payload['retry'].is_a?(Integer) + payload['max_retries'] = payload['retry'] + payload['retry'] = true + end + payload end