lib/rocket_job/worker.rb in rocketjob-2.0.0.rc3 vs lib/rocket_job/worker.rb in rocketjob-2.0.0
- old
+ new
@@ -342,10 +342,10 @@
# Returns [Boolean] whether any job was actually processed
def process_available_jobs
skip_job_ids = []
processed = false
while (job = Job.rocket_job_next_job(name, skip_job_ids)) && !shutting_down?
- logger.fast_tag("Job #{job.id}") do
+ logger.fast_tag("job:#{job.id}") do
if job.rocket_job_work(self)
# Need to skip the specified job due to throttling or no work available
skip_job_ids << job.id
else
processed = true