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 fc6ffd54ef
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
distribute_tasks.py
View file

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