From d067e264ce64ac61d3bbb240b52b8b779e429569 Mon Sep 17 00:00:00 2001
From: dieriba <dieriba.pro@gmail.com>
Date: Wed, 1 Oct 2025 01:27:53 +0200
Subject: [PATCH] fix neg

---
 benchmarks/benchmark_sharding.ts | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/benchmarks/benchmark_sharding.ts b/benchmarks/benchmark_sharding.ts
index 0cab9c1034..b553929136 100644
--- a/benchmarks/benchmark_sharding.ts
+++ b/benchmarks/benchmark_sharding.ts
@@ -306,7 +306,7 @@ async function runShardingBenchmark(
   let completedJobs = 0;
   let lastElapsed = 0;
   let lastCompletedJobs = 0;
-  let totalMonitoringOverhead = 0; // Track cumulative monitoring time
+  let totalMonitoringOverhead = 0;
 
   let didStart = false;
   while (completedJobs < jobsSent) {
@@ -317,16 +317,16 @@ async function runShardingBenchmark(
 
       if (actual_queue < jobsSent) {
         start = Date.now();
+        totalMonitoringOverhead = 0;
         didStart = true;
       }
     } else {
-      await sleep(500);
+      await sleep(1);
       const monitoringStart = Date.now();
       completedJobs = await getCompletedJobsCount(NON_TEST_TAGS, pastJobs);
       totalMonitoringOverhead += Date.now() - monitoringStart;
 
-      const elapsed = start ? Date.now() - start - totalMonitoringOverhead : 0;
-      console.log({ totalMonitoringOverhead });
+      const elapsed = start ? Math.max(0, Date.now() - start - totalMonitoringOverhead) : 0;
       if (nStepsFlow > 0) {
         completedJobs = Math.floor(completedJobs / (nStepsFlow + 1));
       }