lib/rocket_job/supervisor.rb in rocketjob-5.0.0.rc1 vs lib/rocket_job/supervisor.rb in rocketjob-5.0.0

@@ -79,14 +79,14 @@
           else
             break
           end
         end
 
+        synchronize { server.refresh(worker_pool.living_count) }
+
         self.class.wait_for_event(Config.heartbeat_seconds)
 
         break if self.class.shutdown?
-
-        synchronize { server.refresh(worker_pool.living_count) }
       end
     end
 
     def synchronize(&block)
       @mutex.synchronize(&block)