hiro/jobmanager
1
0
Fork 0
mirror of https://github.com/vale981/jobmanager synced 2025-03-05 18:01:38 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

ready to merge

Browse source
This commit is contained in:
Paul Müller 2015-02-17 19:32:13 +01:00
parent 5b28a5f091
commit 8aa90b559b
1 changed files with 2 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
jobmanager/jobmanager.py
View file

@ -283,7 +283,7 @@ class JobManager_Client(object):
traceback.print_exc()
@staticmethod
def __worker_func(func, nice, verbose, server, port, authkey, i, manager_objects, c, m, reset_pbc, njobs=-1):
def __worker_func(func, nice, verbose, server, port, authkey, i, manager_objects, c, m, reset_pbc, njobs):
"""
the wrapper spawned nproc trimes calling and handling self.func
"""
@ -338,9 +338,7 @@ class JobManager_Client(object):
# c) any queue operation (get, put) fails for what ever reason
# d) njobs becomes zero
while njobs != 0:
if njobs > 0:
njobs -= 1
njobs -= 1
# try to get an item from the job_q
try: