diff --git a/src/routers/http/router.rs b/src/routers/http/router.rs index 5780cdb..e146212 100644 --- a/src/routers/http/router.rs +++ b/src/routers/http/router.rs @@ -593,13 +593,6 @@ impl Router { false }; - // Keep a clone for potential cleanup on retry - let worker_for_cleanup = if load_incremented { - Some(worker.clone()) - } else { - None - }; - let response = self .send_typed_request( headers, @@ -617,18 +610,6 @@ impl Router { let status = response.status(); worker.record_outcome(status.is_success() || status.is_client_error()); - // For retryable failures, we need to decrement load since send_typed_request - // won't have done it (it only decrements on success or non-retryable failures) - if is_retryable_status(response.status()) && load_incremented { - if let Some(cleanup_worker) = worker_for_cleanup { - cleanup_worker.decrement_load(); - RouterMetrics::set_running_requests( - cleanup_worker.url(), - cleanup_worker.load(), - ); - } - } - response }, // should_retry predicate