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

added jobmanager ready print for external diagnostics

Browse source
This commit is contained in:
Richard Hartmann 2016-09-26 16:47:25 +02:00
parent 549fd78bed
commit 5dd8686e9a
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
jobmanager/jobmanager.py
View file

@ -1136,6 +1136,10 @@ class JobManager_Server(object):
"""to implement user defined final processing""" """to implement user defined final processing"""
pass pass
def print_jm_ready(self):
# please overwrite for individual hooks to notify that the server process runs
print("jobmanager awaits client results")
def start(self): def start(self):
""" """
starts to loop over incoming results starts to loop over incoming results
@ -1177,6 +1181,8 @@ class JobManager_Server(object):
Progress = progress.ProgressSilentDummy Progress = progress.ProgressSilentDummy
info_line = progress.StringValue(num_of_bytes=100) info_line = progress.StringValue(num_of_bytes=100)
self.print_jm_ready()
with Progress(count = self._numresults, with Progress(count = self._numresults,
max_count = self._numjobs, max_count = self._numjobs,