Skip to content
Snippets Groups Projects
Commit 055aff17 authored by Jeremy Auguste's avatar Jeremy Auguste
Browse files

Slightly changed the output

parent 729b48ad
No related branches found
No related tags found
No related merge requests found
......@@ -18,6 +18,8 @@ class Owner:
self.karma = defaultdict(float)
self.timeleft = 0
self.running = defaultdict(int)
self.running_cores = defaultdict(int)
self.running_gpus = defaultdict(int)
self.resources = defaultdict(int)
self.gpu = defaultdict(int)
self.devices = defaultdict(int)
......@@ -30,6 +32,9 @@ class Owner:
self.resources[job.queue] += job.resources
if job.elapsed_time != 0:
self.running[job.queue] += 1
self.running_cores[job.queue] += job.resources
if job.gpu:
self.running_gpus[job.queue] += job.resources
if job.gpu:
self.gpu[job.queue] += job.resources
for device in job.devices:
......@@ -38,7 +43,14 @@ class Owner:
def print_info(self, show_devices=False):
print("User {} :: Total Time Reserved: {}".format(self.name, datetime.timedelta(seconds=self.timeleft)))
for queue in self.queues.keys():
print("\t{} - Running {}, Resources: {}, GPUs: {}, Karma: {}".format(queue, self.running[queue], self.resources[queue], self.gpu[queue], self.karma[queue]))
print("\t{} - Running: {} jobs ({} cores, {} gpus), Total: {} jobs ({} cores, {} gpus) - Karma: {}".format(queue,
self.running[queue],
self.running_cores[queue],
self.running_gpus[queue],
len(self.queues[queue]),
self.resources[queue],
self.gpu[queue],
self.karma[queue]))
if show_devices and self.devices:
print("Running on: {}".format(" ".join(["{}:{}".format(device, amount) for device, amount in self.devices.items()])))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment