lib/rocket_job/worker.rb in rocketjob-3.0.0.beta3 vs lib/rocket_job/worker.rb in rocketjob-3.0.0.rc1
- old
+ new
@@ -97,10 +97,10 @@
# Process the next available job
# Returns [Boolean] whether any job was actually processed
def process_available_jobs
# Only clear out the current_filter after every `re_check_seconds`
time = Time.now
- if (time - @re_check_start) > re_check_seconds
+ if (time - @re_check_start) > re_check_seconds.to_f
@recheck_start = time
self.current_filter = filter.dup
end
processed = false