diff --git a/performance_measurement/measure_performance.py b/performance_measurement/measure_performance.py
index 20ae91c72..4ec443bfe 100644
--- a/performance_measurement/measure_performance.py
+++ b/performance_measurement/measure_performance.py
@@ -80,7 +80,7 @@ def test_normal(
         # start the stats watcher
         control_plane_stats_dir = os.path.join(trial_dir, "control_plane_stats")
         os.makedirs(control_plane_stats_dir, exist_ok=True)
-        watcher = WatchStats(cluster, "anvil", control_plane_stats_dir)
+        watcher = WatchStats("anvil", control_plane_stats_dir)
         pods_watcher = MetricsApiWatcher(control_plane_stats_dir)
         watcher_thread = threading.Thread(target=watcher.start, args=(cluster,))
         pods_watcher_thread = threading.Thread(target=pods_watcher.start, args=(runner.apiclient,deploy.operator_name))
@@ -113,7 +113,7 @@ def test_normal(
         control_plane_stats_dir = os.path.join(single_operation_trial_dir, "control_plane_stats")
         os.makedirs(control_plane_stats_dir, exist_ok=True)
 
-        watcher = WatchStats(cluster, "anvil", control_plane_stats_dir)
+        watcher = WatchStats("anvil", control_plane_stats_dir)
         pods_watcher = MetricsApiWatcher(control_plane_stats_dir)
         
         gen = 0