diff --git a/distribute_tasks.py b/distribute_tasks.py index 4401350..2dbe95b 100644 --- a/distribute_tasks.py +++ b/distribute_tasks.py @@ -195,7 +195,9 @@ class Orchestrator: if len(self.threads) >= self.tasks.initial_task_count: return self.threads.append( - WorkingThread(host, self.tasks.queue, self.failures) + WorkingThread( + host, host_details["addr"], self.tasks.queue, self.failures + ) ) def start(self):