From fc6ffd54ef1b776d987be7a9b6ed17104ca6b49f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Th=C3=A9ophile=20Bastian?= Date: Thu, 29 Aug 2019 14:53:06 +0200 Subject: [PATCH] Fix WorkingThread instances --- distribute_tasks.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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):