Loading config/lassen.yaml +1 −1 Original line number Diff line number Diff line Loading @@ -120,7 +120,7 @@ cooling: w_cts_key: "simulator[1].centralEnergyPlant[1].coolingTowerLoop[1].summary.W_flow_CT_kW" network: topology: fat-tree network_max_bw: 1000000000.0 network_max_bw: 12.5e9 fattree_k: 32 dragonfly_d: 11 dragonfly_a: 9 Loading raps/workloads/network.py +10 −4 Original line number Diff line number Diff line Loading @@ -16,13 +16,15 @@ class NetworkTestWorkload: # Hard-coded configuration # -------------------------------------------------------- # Define per-job properties bw = 1e10 job_configs = [ # (job_id, node_list, bandwidth_bytes_per_tick) (1, [0, 1], 1e11), # 2-node job (2, [1, 2], 8e11), # overlaps node 1 (causes congestion) (3, [256], 1e12), # isolated single-node job (1, [0, 1], bw), # 2-node job # (2, [1, 2], bw), # Job 2 overlaps node 1 (causes congestion) (2, [128, 129], bw), # Job 2 on a distant rack (no shared link) (3, [256], bw), # isolated single-node job (4, [512, 513, 514], 5e11), # multi-node but separate (5, [1020], 1e12), # distant single-node job (5, [1020], bw), # distant single-node job ] runtime = 900 # seconds Loading Loading @@ -53,4 +55,8 @@ class NetworkTestWorkload: jobs.append(Job(job_info)) print(f"[DEBUG] Created net_job_{job_id} nodes={node_list} bw={bw:.2e}") print("\n[DEBUG] Requested node assignments:") for job in jobs: print(f" Job {job.id}: nodes_required={job.nodes_required}, scheduled_nodes={job.scheduled_nodes}") return jobs Loading
config/lassen.yaml +1 −1 Original line number Diff line number Diff line Loading @@ -120,7 +120,7 @@ cooling: w_cts_key: "simulator[1].centralEnergyPlant[1].coolingTowerLoop[1].summary.W_flow_CT_kW" network: topology: fat-tree network_max_bw: 1000000000.0 network_max_bw: 12.5e9 fattree_k: 32 dragonfly_d: 11 dragonfly_a: 9 Loading
raps/workloads/network.py +10 −4 Original line number Diff line number Diff line Loading @@ -16,13 +16,15 @@ class NetworkTestWorkload: # Hard-coded configuration # -------------------------------------------------------- # Define per-job properties bw = 1e10 job_configs = [ # (job_id, node_list, bandwidth_bytes_per_tick) (1, [0, 1], 1e11), # 2-node job (2, [1, 2], 8e11), # overlaps node 1 (causes congestion) (3, [256], 1e12), # isolated single-node job (1, [0, 1], bw), # 2-node job # (2, [1, 2], bw), # Job 2 overlaps node 1 (causes congestion) (2, [128, 129], bw), # Job 2 on a distant rack (no shared link) (3, [256], bw), # isolated single-node job (4, [512, 513, 514], 5e11), # multi-node but separate (5, [1020], 1e12), # distant single-node job (5, [1020], bw), # distant single-node job ] runtime = 900 # seconds Loading Loading @@ -53,4 +55,8 @@ class NetworkTestWorkload: jobs.append(Job(job_info)) print(f"[DEBUG] Created net_job_{job_id} nodes={node_list} bw={bw:.2e}") print("\n[DEBUG] Requested node assignments:") for job in jobs: print(f" Job {job.id}: nodes_required={job.nodes_required}, scheduled_nodes={job.scheduled_nodes}") return jobs