mirror of
https://github.com/vale981/jobmanager
synced 2025-03-05 09:51:38 -05:00
added speed to status infoline
This commit is contained in:
parent
078c847282
commit
97bdd70d6f
1 changed files with 4 additions and 4 deletions
|
@ -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 {}b, jobs: rem.:{}, "+
|
||||
info_line.value = ("res_q size:{} {}/s {}, jobs: rem.:{}, "+
|
||||
"done:{}, failed:{}, prog.:{}, "+
|
||||
"timeout in:{}s").format(self.result_q.qsize(), data_speed, bytes_recieved,
|
||||
"timeout in:{}s").format(self.result_q.qsize(), data_speed, humanize_size(bytes_recieved),
|
||||
jobqsize,
|
||||
markeditems,
|
||||
failqsize,
|
||||
numjobs.value - numresults.value - jobqsize,
|
||||
time_left).encode('utf-8')
|
||||
else:
|
||||
info_line.value = ("result_q size:{} {}/s {}b, jobs: remaining:{}, "+
|
||||
"done:{}, failed:{}, in progress:{}").format(self.result_q.qsize(), data_speed, bytes_recieved,
|
||||
info_line.value = ("result_q size:{} {}/s {}, jobs: remaining:{}, "+
|
||||
"done:{}, failed:{}, in progress:{}").format(self.result_q.qsize(), data_speed, humanize_size(bytes_recieved),
|
||||
jobqsize,
|
||||
markeditems,
|
||||
failqsize,
|
||||
|
|
Loading…
Add table
Reference in a new issue