Commit 998b9919 authored by Daniele Venzano's avatar Daniele Venzano

Check for dead services every time the scheduler is triggered to prevent deadlock conditions

parent 14f2fad7
......@@ -182,10 +182,10 @@ class ZoeElasticScheduler:
if self.loop_quit:
break
self._check_dead_services()
if len(self.queue) == 0:
log.debug("Scheduler loop has been triggered, but the queue is empty")
self.core_limit_recalc_trigger.set()
self._check_dead_services()
continue
log.debug("Scheduler loop has been triggered")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment