controller: Add experiment_index to p_list

Fraunhofer-AISEC · Nov 2, 2023 · 92effdd · 92effdd
1 parent fc98c6c
commit 92effdd
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/controller.py b/controller.py
@@ -735,7 +735,6 @@ def controller(
             and queue_output.qsize() < queuedepth
         ):
             faults = faultlist[itter]
-            itter += 1
 
             p = Process(
                 name=f"worker_{faults['index']}",
@@ -754,12 +753,16 @@ def controller(
                 ),
             )
             p.start()
-            p_list.append({"process": p, "start_time": time.time()})
+            p_list.append(
+                {"process": p, "start_time": time.time(), "experiment_index": itter}
+            )
             clogger.debug(f"Started worker {faults['index']}. Running: {len(p_list)}.")
             clogger.debug(f"Fault address: {faults['faultlist'][0].address}")
             clogger.debug(
                 f"Fault trigger address: {faults['faultlist'][0].trigger.address}"
             )
+
+            itter += 1
         else:
             time.sleep(0.005)  # wait for workers to finish, scheduler can wait