lib/good_job/scheduler.rb in good_job-2.4.0 vs lib/good_job/scheduler.rb in good_job-2.4.1
- old
+ new
@@ -228,9 +228,10 @@
# @param delay [Integer]
# @return [void]
def create_task(delay = 0)
future = Concurrent::ScheduledTask.new(delay, args: [performer], executor: executor, timer_set: timer_set) do |thr_performer|
+ Thread.current.name = Thread.current.name.sub("-worker-", "-thread-") if Thread.current.name
Rails.application.reloader.wrap do
thr_performer.next
end
end
future.add_observer(self, :task_observer)