Convert 'retry' to string for ES compatibility when integer (#5)

iMacTia · Aug 23, 2018 · 99691d0 · 99691d0
1 parent 74b5432
commit 99691d0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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