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):