We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 884b440 + 195249a commit 34e3278Copy full SHA for 34e3278
lib/chitragupta/util.rb
@@ -92,9 +92,14 @@ def populate_worker_data(data, message)
92
if Thread.current[:sidekiq_context].nil?
93
return
94
end
95
- worker_name, job_id = Thread.current[:sidekiq_context][0].split
96
- data[:data][:job_id] = job_id
97
- data[:data][:worker_name] = worker_name
+ if Thread.current[:sidekiq_context].is_a?(Hash)
+ data[:data][:job_id] = Thread.current[:sidekiq_context][:jid]
+ data[:data][:worker_name] = Thread.current[:sidekiq_context][:class]
98
+ else
99
+ worker_name, job_id = Thread.current[:sidekiq_context][0].split
100
+ data[:data][:job_id] = job_id
101
+ data[:data][:worker_name] = worker_name
102
+ end
103
104
105
def initialize_data(message)
0 commit comments