lib/good_job/scheduler.rb in good_job-2.1.0 vs lib/good_job/scheduler.rb in good_job-2.2.0

@@ -242,11 +242,11 @@
     # @param payload [Hash]
     # @return [void]
     def instrument(name, payload = {}, &block)
       payload = payload.reverse_merge({
                                         scheduler: self,
-                                        process_id: GoodJob::CurrentExecution.process_id,
-                                        thread_name: GoodJob::CurrentExecution.thread_name,
+                                        process_id: GoodJob::CurrentThread.process_id,
+                                        thread_name: GoodJob::CurrentThread.thread_name,
                                       })
 
       ActiveSupport::Notifications.instrument("#{name}.good_job", payload, &block)
     end