lib/rocket_job/active_worker.rb in rocketjob-5.1.1 vs lib/rocket_job/active_worker.rb in rocketjob-5.2.0.beta1

@@ -27,9 +27,10 @@
 
     # 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?(active_worker.server_name)
+
         active_worker.job.requeue!(active_worker.server_name)
       end
     end
 
     def initialize(name, started_at, job)