vacp2p
/
research
mirror of https://github.com/vacp2p/research.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

status command

This commit is contained in:
0xFugue 2023-08-07 11:59:48 +05:30
parent b2404b1acc
commit a895402748
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
waku_scalability/waku_scaling.py
View File

@ -35,6 +35,7 @@ class Keys:
PER_NODE = "per_node"
BMARK = "benchmark"
OPREFIX = "out"
STATUS = "status"
# MSGPHR = "msgphr"
# SIZE = "size"
@ -654,15 +655,16 @@ def cli(ctx: typer.Context,
@app.command()
def status(ctx: typer.Context, status_config: Path):
status_json = _sanity_check(status_config, [ Keys.STATUS ], Keys.JSON)
explore = batch_json[Keys.BATCH][Keys.EXPLORE]
per_node = batch_json[Keys.BATCH][Keys.PER_NODE]
runs = batch_json[Keys.BATCH][Keys.RUNS]
explore = batch_json[Keys.STATUS][Keys.EXPLORE]
per_node = batch_json[Keys.STATUS][Keys.PER_NODE]
runs = batch_json[Keys.STATUS][Keys.RUNS]
for r in runs:
run = runs[r]
run["per_hop_delay"] = 0.010
if not per_node:
for k, v in run["messages"].items():
run["messages"][k]["msgpsec"] = run["messages"][k]["msgpsec"] / run["num_nodes"]
# how to parameterise
analysis = WakuAnalysis(**run)
analysis.run(explore=explore)
print(f'batch: done')