hiro/jobmanager
1
0
Fork 0
mirror of https://github.com/vale981/jobmanager synced 2025-03-05 09:51:38 -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 22:36:24 +02:00
parent 978795edeb
commit b8530cbbf9
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
jobmanager/jobmanager.py
View file

@ -1775,7 +1775,10 @@ class JobManager_Server(object):
old_bytes = bytes_recieved old_bytes = bytes_recieved
bytes_recieved = self.result_q.get_bytes_recieved() bytes_recieved = self.result_q.get_bytes_recieved()
curr_time = time.time() curr_time = time.time()
data_speed = humanize_size((bytes_recieved - old_bytes)) / (curr_time - old_time) data_speed = humanize_size((bytes_recieved - old_bytes) / (curr_time - old_time))
print()
print(bytes_recieved, (bytes_recieved - old_bytes), (curr_time - old_time), (bytes_recieved - old_bytes) / (curr_time - old_time))
print()
if (self.timeout is not None): if (self.timeout is not None):
time_left = int(self.timeout - self.__wait_before_stop - (datetime.now() - self.start_time).total_seconds()) time_left = int(self.timeout - self.__wait_before_stop - (datetime.now() - self.start_time).total_seconds())
if time_left < 0: if time_left < 0: