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

start server with no jobs will NOT raise en Exception anymore -> simply show note, modified allignment of JobmanagerServer.show_statistics

Browse source
This commit is contained in:
cimatosa 2015-01-13 17:44:51 +01:00
parent c1704a8b6e
commit d0650108d4
1 changed files with 16 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
jobmanager/jobmanager.py
View file

@ -22,6 +22,7 @@ __all__ = ["JobManager_Client",
"JobManager_Local",
"JobManager_Server",
"hashDict",
"hashableCopyOfNumpyArray"
]
@ -536,19 +537,22 @@ class JobManager_Server(object):
failed = self.fail_q.qsize()
all_processed = succeeded + failed
print("total number of jobs : {}".format(all_jobs))
print(" processed : {}".format(all_processed))
print(" succeeded : {}".format(succeeded))
print(" failed : {}".format(failed))
id = self._identifier + ": "
id2 = progress.ESC_HIDDEN + self._identifier + progress.ESC_RESET_HIDDEN + "| "
print("{}total number of jobs : {}".format(id, all_jobs))
print("{} processed : {}".format(id2, all_processed))
print("{} succeeded : {}".format(id2, succeeded))
print("{} failed : {}".format(id2, failed))
all_not_processed = all_jobs - all_processed
not_queried = self.job_q.qsize()
queried_but_not_processed = all_not_processed - not_queried
print(" not processed : {}".format(all_not_processed))
print(" queried : {}".format(queried_but_not_processed))
print(" not queried yet : {}".format(not_queried))
print("len(args_set) : {}".format(len(self.args_set)))
print("{} not processed : {}".format(id2, all_not_processed))
print("{} queried : {}".format(id2, queried_but_not_processed))
print("{} not queried yet : {}".format(id2, not_queried))
print("{}len(args_set) : {}".format(id2, len(self.args_set)))
if (all_not_processed + failed) != len(self.args_set):
raise RuntimeWarning("'all_not_processed != len(self.args_set)' something is inconsistent!")
@ -681,7 +685,10 @@ class JobManager_Server(object):
raise RuntimeError("inconsistency detected! (self.numjobs - self.numresults) != len(self.args_set)! use JobManager_Server.put_arg to put arguments to the job_q")
if self.numjobs == 0:
raise RuntimeError("no jobs to process! use JobManager_Server.put_arg to put arguments to the job_q")
print("{}: WARNING no jobs to process! use JobManager_Server.put_arg to put arguments to the job_q".format(self._identifier))
return
else:
print("{}: start with {} jobs in queue".format(self._identifier, self.numjobs))
Signal_to_sys_exit(signals=[signal.SIGTERM, signal.SIGINT], verbose = self.verbose)
pid = os.getpid()