lib/rocket_job/active_worker.rb in rocketjob-3.0.1 vs lib/rocket_job/active_worker.rb in rocketjob-3.0.2

@@ -25,10 +25,10 @@
     end
 
     # Requeues all jobs for which the workers have disappeared
     def self.requeue_zombies
       all.each do |active_worker|
-        next if !active_worker.zombie? || !active_worker.job.may_requeue?
+        next if !active_worker.zombie? || !active_worker.job.may_requeue?(active_worker.server_name)
         active_worker.job.requeue!(active_worker.server_name)
       end
     end
 
     def initialize(name, started_at, job)