lib/resque/worker.rb in resque-1.17.0 vs lib/resque/worker.rb in resque-1.17.1
- old
+ new
@@ -126,11 +126,11 @@
procline "Forked #{@child} at #{Time.now.to_i}"
Process.wait
else
procline "Processing #{job.queue} since #{Time.now.to_i}"
perform(job, &block)
- exit unless @cant_fork
+ exit! unless @cant_fork
end
done_working
@child = nil
else
@@ -300,10 +300,10 @@
# are we paused?
def paused?
@paused
end
-
+
# Stop processing jobs after the current one has completed (if we're
# currently running one).
def pause_processing
log "USR2 received; pausing job processing"
@paused = true