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 speed to status infoline

Browse source
This commit is contained in:
Richard Hartmann 2019-06-03 21:55:11 +02:00
parent fd4a9a7feb
commit 078c847282
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
jobmanager/jobmanager.py
View file

@ -1744,7 +1744,7 @@ class JobManager_Server(object):
When finished, or on exception call stop() afterwards to shut down gracefully.
"""
info_line = progress.StringValue(num_of_bytes=100)
info_line = progress.StringValue(num_of_bytes=128)
numresults = progress.UnsignedIntValue(self.job_q.marked_items() + self.fail_q.qsize())
numjobs = progress.UnsignedIntValue(self.job_q.put_items())
@ -1781,17 +1781,17 @@ class JobManager_Server(object):
self.stat.stop()
log.warning("timeout ({}s) exceeded -> quit server".format(self.timeout))
break
info_line.value = ("res_q size:{} {}/s, jobs: rem.:{}, "+
info_line.value = ("res_q size:{} {}/s {}b, jobs: rem.:{}, "+
"done:{}, failed:{}, prog.:{}, "+
"timeout in:{}s").format(self.result_q.qsize(), data_speed,
"timeout in:{}s").format(self.result_q.qsize(), data_speed, bytes_recieved,
jobqsize,
markeditems,
failqsize,
numjobs.value - numresults.value - jobqsize,
time_left).encode('utf-8')
else:
info_line.value = ("result_q size:{} {}/s, jobs: remaining:{}, "+
"done:{}, failed:{}, in progress:{}").format(self.result_q.qsize(), data_speed,
info_line.value = ("result_q size:{} {}/s {}b, jobs: remaining:{}, "+
"done:{}, failed:{}, in progress:{}").format(self.result_q.qsize(), data_speed, bytes_recieved,
jobqsize,
markeditems,
failqsize,