improved scheduler, thanks Niphlod

2012-11-05 12:39:17 -06:00
parent 22e2b4864f
commit ad2b332fa0
2 changed files with 3 additions and 1 deletions
@@ -1 +1 @@
-Version 2.2.1 (2012-11-04 20:45:19) stable
+Version 2.2.1 (2012-11-05 12:39:09) stable
@@ -739,6 +739,8 @@ class Scheduler(MetaScheduler):
                    db(sw.worker_name == self.worker_name).update(
                        last_heartbeat=now, status=ACTIVE)
                    self.worker_status[1] = 1  # re-activating the process
+                    if self.worker_status[0] <> RUNNING:
+                        self.worker_status[0] = ACTIVE

            self.do_assign_tasks = False