Notebook done for figure 8
This commit is contained in:
parent
3fea98866d
commit
5a8db7b2a2
4 changed files with 542 additions and 5 deletions
File diff suppressed because one or more lines are too long
|
@ -99,7 +99,7 @@ def increment_reserv_bucket(bucket, taskid, value):
|
||||||
idx = 40 if value >= 1 else (int(value * 40) + 1)
|
idx = 40 if value >= 1 else (int(value * 40) + 1)
|
||||||
|
|
||||||
if taskid not in bucket:
|
if taskid not in bucket:
|
||||||
bucket[taskid] = [0] * (len(ceils) + 1)
|
bucket[taskid] = [0] * 41
|
||||||
bucket[taskid][idx] += 1
|
bucket[taskid][idx] += 1
|
||||||
|
|
||||||
def bucket_sum_per_termination(bucket, last_term_by_id):
|
def bucket_sum_per_termination(bucket, last_term_by_id):
|
||||||
|
@ -119,7 +119,6 @@ def for_each_joined(x):
|
||||||
ts = sorted(ts, key=lambda x: x.time)
|
ts = sorted(ts, key=lambda x: x.time)
|
||||||
last_req_by_id = {} # map taskid -> last known req [cpu, ram] (data removed when task terminates)
|
last_req_by_id = {} # map taskid -> last known req [cpu, ram] (data removed when task terminates)
|
||||||
|
|
||||||
reserv_ceils = [0]
|
|
||||||
cpu_reservs_by_id = {}
|
cpu_reservs_by_id = {}
|
||||||
ram_reservs_by_id = {}
|
ram_reservs_by_id = {}
|
||||||
|
|
||||||
|
|
510
figure_8/figure_8.ipynb
Normal file
510
figure_8/figure_8.ipynb
Normal file
File diff suppressed because one or more lines are too long
BIN
status.ods
BIN
status.ods
Binary file not shown.
Loading…
Reference in a new issue