From f441944b323b11382a5dfe891fb719babcab631a 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 | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/distribute_tasks.py b/distribute_tasks.py index 4401350..5897cff 100644 --- a/distribute_tasks.py +++ b/distribute_tasks.py @@ -131,7 +131,7 @@ class HostsFile: raise Exception("Host has no {}".format(field)) self.hosts[entry["host"]] = { "cores": entry["cores"], - "ip": socket.gethostbyname(entry["host"]), + "addr": socket.gethostbyname(entry["host"]), } @@ -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):