Commit 39262af4 authored by Maude Le Jeune's avatar Maude Le Jeune
Browse files

attempt to solve weird crash

parent c3a37d0f
...@@ -411,8 +411,11 @@ class Scheduler(): ...@@ -411,8 +411,11 @@ class Scheduler():
self.stopping = True self.stopping = True
for i in range(self.nb_worker): for i in range(self.nb_worker):
self.task_queue.put(None) self.task_queue.put(None)
# wait for workers to complete # wait for workers to complete
logger.info("Waiting for workers to complete...") logger.info("Waiting for workers to complete...")
if self.nb_worker == 0:
self.stop_event.set()
self.stop_event.wait() self.stop_event.wait()
logger.info("No more workers. Stopping the sqltracker ...") logger.info("No more workers. Stopping the sqltracker ...")
self.tracker.stop() self.tracker.stop()
......
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