terminate mrq-worker if scheduler greenlet fails

yssource · Jul 18, 2016 · 2d338ed · 2d338ed
1 parent aa2a294
commit 2d338ed
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/mrq/worker.py b/mrq/worker.py
@@ -453,6 +453,10 @@ def work_loop(self, max_jobs=None):
                 if self.graceful_stop:
                     break
 
+                # If the scheduler greenlet are crashed, fail loudly.
+                if self.config["scheduler"] and not self.greenlets["scheduler"]:
+                    break
+
                 while True:
 
                     free_pool_slots = self.gevent_pool.free_count()