lib/rocket_job/batch/worker.rb in rocketjob-4.3.0.beta2 vs lib/rocket_job/batch/worker.rb in rocketjob-5.0.0.beta
- old
+ new
@@ -60,10 +60,10 @@
self.class.send(:rocket_job_merge_filter, filter, throttle_filter_id)
return true
end
# Allow new jobs with a higher priority to interrupt this job
- break if (Time.now - start_time) >= Config.instance.re_check_seconds
+ break if (Time.now - start_time) >= Config.re_check_seconds
end
false
end
# Prior to a job being made available for processing it can be processed one