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

Compare commits

base: tobast:fc6ffd54ef1b776d987be7a9b6ed17104ca6b49f
Branches Tags
tobast:master
...
compare: tobast:f441944b323b11382a5dfe891fb719babcab631a
Branches Tags
tobast:master

1 commit
fc6ffd54ef ... f441944b32

Author SHA1 Message Date
Théophile Bastian f441944b32 Fix WorkingThread instances 2019-08-29 14:54:35 +02:00
1 changed files with 4 additions and 2 deletions
Show stats 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):