diff --git a/tests/infra/basicperf.py b/tests/infra/basicperf.py
index dbba6e14be41..926c706f0c4a 100644
--- a/tests/infra/basicperf.py
+++ b/tests/infra/basicperf.py
@@ -493,7 +493,7 @@ def table():
                     pl.col("receiveTime") < earliest_end
                 )
                 all_active_duration_s = (earliest_end - latest_start).total_seconds()
-                all_active_throughput = len(agg_all_active) / duration_s
+                all_active_throughput = len(agg_all_active) / all_active_duration_s
                 statistics[
                     "all_clients_active_average_throughput_tx/s"
                 ] = all_active_throughput