Fix WorkingThread instances

2019-08-29 14:53:06 +02:00
1 changed files with 3 additions and 1 deletions
--- 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):