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

Fixed naming issues

parent 9e4b61fd
Branches
No related tags found
No related merge requests found
...@@ -24,9 +24,9 @@ class Owner: ...@@ -24,9 +24,9 @@ class Owner:
self.queues[job.queue].append(job) self.queues[job.queue].append(job)
if job.karma > self.karma: if job.karma > self.karma:
self.karma = job.karma self.karma = job.karma
self.timeleft += job.duration - job.exec_time self.timeleft += job.wall_time - job.elapsed_time
self.resources[job.queue] += job.resources self.resources[job.queue] += job.resources
if job.start_time != 0: if job.elapsed_time != 0:
self.running[job.queue] += 1 self.running[job.queue] += 1
if job.gpu: if job.gpu:
self.gpu[job.queue] += job.resources self.gpu[job.queue] += job.resources
...@@ -38,9 +38,9 @@ class Owner: ...@@ -38,9 +38,9 @@ class Owner:
class Job: class Job:
def __init__(self, job_id, start_time, wall_time, resources, devices, gpu, queue, karma): def __init__(self, job_id, elapsed_time, wall_time, resources, devices, gpu, queue, karma):
self.job_id = job_id self.job_id = job_id
self.start_time = start_time self.elapsed_time = elapsed_time
self.wall_time = wall_time self.wall_time = wall_time
self.resources = resources self.resources = resources
self.devices = devices self.devices = devices
...@@ -79,7 +79,7 @@ def main(): ...@@ -79,7 +79,7 @@ def main():
for job_id, job_info in stats_yaml.items(): for job_id, job_info in stats_yaml.items():
if job_info["owner"] not in owners: if job_info["owner"] not in owners:
owners[job_info["owner"]] = Owner(job_info["owner"]) owners[job_info["owner"]] = Owner(job_info["owner"])
start_time = 0 if job_info["startTime"] == 0 else time.time() - job_info["startTime"] elapsed_time = 0 if job_info["startTime"] == 0 else time.time() - job_info["startTime"]
tokens = re.search(walltime_pattern, job_info["message"]).group(1).split(':') tokens = re.search(walltime_pattern, job_info["message"]).group(1).split(':')
wall_time = int(tokens[0]) * 3600 + int(tokens[1]) * 60 + int(tokens[2]) wall_time = int(tokens[0]) * 3600 + int(tokens[1]) * 60 + int(tokens[2])
resources = int(re.search(resources_pattern, job_info["message"]).group(1)) resources = int(re.search(resources_pattern, job_info["message"]).group(1))
...@@ -87,7 +87,7 @@ def main(): ...@@ -87,7 +87,7 @@ def main():
karma = float(re.search(karma_pattern, job_info["message"]).group(1)) karma = float(re.search(karma_pattern, job_info["message"]).group(1))
devices = job_info["assigned_network_address"] devices = job_info["assigned_network_address"]
gpu = re.search(gpu_pattern, job_info["properties"]) is not None gpu = re.search(gpu_pattern, job_info["properties"]) is not None
job = Job(job_id, start_time, wall_time, resources, devices, gpu, queue, karma) job = Job(job_id, elapsed_time, wall_time, resources, devices, gpu, queue, karma)
owners[job_info["owner"]].add_job(job) owners[job_info["owner"]].add_job(job)
for owner in owners.values(): for owner in owners.values():
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment