diff --git a/distribute_tasks.py b/distribute_tasks.py index bcc46f6..eeeaca2 100644 --- a/distribute_tasks.py +++ b/distribute_tasks.py @@ -3,6 +3,7 @@ import threading import queue import sys +import time import yaml import paramiko @@ -175,6 +176,7 @@ class Orchestrator: def start(self): for thread in self.threads: thread.start() + time.sleep(0.1) for thread in self.threads: while thread.is_alive():