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

changed some error/status prints

Browse source
This commit is contained in:
cimatosa 2015-03-27 10:36:55 +01:00
parent c68fed4c83
commit 13b8c83995
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
jobmanager/jobmanager.py
View file

@ -284,9 +284,8 @@ class JobManager_Client(object):
@staticmethod @staticmethod
def _handle_unexpected_queue_error(verbose, identifier): def _handle_unexpected_queue_error(verbose, identifier):
print("{}: unexpected fatal Error, I guess the server went down, can't do anything, terminate now!".format(identifier))
if verbose > 0: if verbose > 0:
print("{}: unexpected Error, I guess the server went down, can't do anything, terminate now!".format(identifier))
if verbose > 1:
traceback.print_exc() traceback.print_exc()
@staticmethod @staticmethod
@ -447,7 +446,7 @@ class JobManager_Client(object):
# wait some time in between # wait some time in between
except ConnectionResetError as e: except ConnectionResetError as e:
if self.vebose > 0: if self.vebose > 0:
print("{}: ConnectionResetError ({}) wait {}s and try to reconnect".format(self._identifier, print("{}: ConnectionResetError ({}) wait {}s and try to reconnect".format(identifier,
e.args[0], e.args[0],
wait)) wait))
err_msg += "{}\n".format(e.args) err_msg += "{}\n".format(e.args)
@ -461,7 +460,7 @@ class JobManager_Client(object):
raise e raise e
except Exception as e: except Exception as e:
JobManager_Client._handle_unexpected_queue_error(e, verbose, identifier) JobManager_Client._handle_unexpected_queue_error(verbose, identifier)
break break
cnt += 1 cnt += 1
@ -1033,7 +1032,7 @@ class JobManager_Server(object):
print("{}: WARNING no jobs to process! use JobManager_Server.put_arg to put arguments to the job_q".format(self._identifier)) print("{}: WARNING no jobs to process! use JobManager_Server.put_arg to put arguments to the job_q".format(self._identifier))
return return
else: else:
print("{}: start with {} jobs in queue".format(self._identifier, self.numjobs)) print("{}: started (host:{} authkey:{} port:{} jobs:{})".format(self._identifier, self.hostname, self.authkey.decode(), self.port, self.numjobs))
Signal_to_sys_exit(signals=[signal.SIGTERM, signal.SIGINT], verbose = self.verbose) Signal_to_sys_exit(signals=[signal.SIGTERM, signal.SIGINT], verbose = self.verbose)
pid = os.getpid() pid = os.getpid()