Fix

Signed-off-by: Tyler Gu <[email protected]>
xlab-uiuc · Nov 19, 2023 · 63a309d · 63a309d
1 parent 883b65d
commit 63a309d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/performance_measurement/measure_performance.py b/performance_measurement/measure_performance.py
@@ -76,6 +76,7 @@ def test_normal(
         os.makedirs(control_plane_stats_dir, exist_ok=True)
         watcher = WatchStats(cluster, "anvil", control_plane_stats_dir)
         watcher_thread = threading.Thread(target=watcher.start)
+        watcher_thread.start()
 
         runner = MeasurementRunner(
             namespace, crd, trial_dir, kubeconfig, context_name)
@@ -111,6 +112,7 @@ def test_normal(
 
             watcher = WatchStats(cluster, "anvil", control_plane_stats_dir)
             watcher_thread = threading.Thread(target=watcher.start)
+            watcher_thread.start()
             measurement_result = runner.run(workload, sts_name_f, ds_name_f, gen)
             if measurement_result is not None:
                 measurement_result_file = f"{single_operation_trial_dir}/measurement_result_{gen:03d}.json"