Compare commits

...

1 commit

Author SHA1 Message Date
Théophile Bastian f441944b32 Fix WorkingThread instances 2019-08-29 14:54:35 +02:00

View file

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