tobast/distribute_shell_tasks
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Fix WorkingThread instances

Browse source
This commit is contained in:
Théophile Bastian 2019-08-29 14:53:06 +02:00
parent 55cab19e33
commit f441944b32
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
distribute_tasks.py
View file

@ -131,7 +131,7 @@ class HostsFile:
raise Exception("Host has no {}".format(field)) raise Exception("Host has no {}".format(field))
self.hosts[entry["host"]] = { self.hosts[entry["host"]] = {
"cores": entry["cores"], "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: if len(self.threads) >= self.tasks.initial_task_count:
return return
self.threads.append( self.threads.append(
WorkingThread(host, self.tasks.queue, self.failures) WorkingThread(
host, host_details["addr"], self.tasks.queue, self.failures
)
) )
def start(self): def start(self):