lib/nadir/plugins/sidekiq.rb in nadir-1.1.0 vs lib/nadir/plugins/sidekiq.rb in nadir-1.1.1

@@ -1,9 +1,21 @@
 module Nadir
   class Sidekiq
     def self.notify(exception, context)
-      job_params = context[:job].slice('class', 'args', 'retry_count', 'queue', 'jid')
-      location = context[:job]['class']
+      if context[:job]['class'] == 'ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper'
+        job_params = {
+          class: context[:job]['args'].first['job_class'],
+          args: context[:job]['args'].first['arguments'],
+          queue: context[:job]['args'].first['queue_name'],
+          job_id: context[:job]['args'].first['job_id'],
+          retry_count: context[:job]['retry_count'],
+          jid: context[:job]['jid'],
+        }
+        location = job_params[:class]
+      else
+        job_params = context[:job].slice('class', 'args', 'retry_count', 'queue', 'jid')
+        location = job_params['class']
+      end
 
       Nadir.notify exception, job: job_params, location: location
     end
   end
 end