lib/rocket_job/worker.rb in rocketjob-3.1.0 vs lib/rocket_job/worker.rb in rocketjob-3.2.0
- old
+ new
@@ -100,10 +100,10 @@
while !shutdown?
reset_filter_if_expired
job = Job.rocket_job_next_job(name, current_filter)
break unless job
- logger.fast_tag("job:#{job.id}") do
+ SemanticLogger.named_tagged(job: job.id.to_s) do
unless job.rocket_job_work(self, false, current_filter)
processed = true
end
end
end