diff --git a/sgl-model-gateway/src/core/worker_registry.rs b/sgl-model-gateway/src/core/worker_registry.rs index 4bbd38f36..8fc0c00b3 100644 --- a/sgl-model-gateway/src/core/worker_registry.rs +++ b/sgl-model-gateway/src/core/worker_registry.rs @@ -427,10 +427,6 @@ impl WorkerRegistry { let mut interval = tokio::time::interval(tokio::time::Duration::from_secs(check_interval_secs)); - // Counter for periodic load reset (every 10 health check cycles) - let mut check_count = 0u64; - const LOAD_RESET_INTERVAL: u64 = 10; - loop { interval.tick().await; @@ -458,15 +454,6 @@ impl WorkerRegistry { }) .collect(); futures::future::join_all(health_futures).await; - - // Reset loads periodically - check_count += 1; - if check_count.is_multiple_of(LOAD_RESET_INTERVAL) { - tracing::debug!("Resetting worker loads (cycle {})", check_count); - for worker in &workers { - worker.reset_load(); - } - } } });