From e4873d043969b5b6f5fea88c66499dc6f0ce16b2 Mon Sep 17 00:00:00 2001 From: fzyzcjy <5236035+fzyzcjy@users.noreply.github.com> Date: Fri, 12 Dec 2025 12:00:55 +0800 Subject: [PATCH] Super tiny remove sgl_router_active_workers (#14891) --- sgl-model-gateway/src/observability/metrics.rs | 8 -------- sgl-model-gateway/src/routers/http/router.rs | 10 ---------- 2 files changed, 18 deletions(-) diff --git a/sgl-model-gateway/src/observability/metrics.rs b/sgl-model-gateway/src/observability/metrics.rs index ad8f93b1a..28fac8d03 100644 --- a/sgl-model-gateway/src/observability/metrics.rs +++ b/sgl-model-gateway/src/observability/metrics.rs @@ -359,10 +359,6 @@ impl RouterMetrics { .increment(1); } - pub fn set_active_workers(count: usize) { - gauge!("sgl_router_active_workers").set(count as f64); - } - pub fn set_worker_health(worker_url: &str, healthy: bool) { gauge!("sgl_router_worker_health", "worker" => worker_url.to_string() @@ -928,7 +924,6 @@ mod tests { RouterMetrics::record_request_error("/generate", "timeout"); RouterMetrics::record_retry("/generate"); - RouterMetrics::set_active_workers(5); RouterMetrics::set_worker_health("http://worker1", true); RouterMetrics::set_worker_load("http://worker1", 10); RouterMetrics::record_processed_request("http://worker1"); @@ -1081,9 +1076,6 @@ mod tests { #[test] fn test_extreme_metric_values() { - RouterMetrics::set_active_workers(0); - RouterMetrics::set_active_workers(usize::MAX); - RouterMetrics::set_worker_load("worker", 0); RouterMetrics::set_worker_load("worker", usize::MAX); diff --git a/sgl-model-gateway/src/routers/http/router.rs b/sgl-model-gateway/src/routers/http/router.rs index 82c312eb3..3a3d06a4f 100644 --- a/sgl-model-gateway/src/routers/http/router.rs +++ b/sgl-model-gateway/src/routers/http/router.rs @@ -54,16 +54,6 @@ pub struct Router { impl Router { /// Create a new router with injected policy and client pub async fn new(ctx: &Arc) -> Result { - let workers = ctx.worker_registry.get_workers_filtered( - None, // any model - Some(WorkerType::Regular), - Some(ConnectionMode::Http), - None, // any runtime type - false, // include all workers - ); - - RouterMetrics::set_active_workers(workers.len()); - Ok(Router { worker_registry: ctx.worker_registry.clone(), policy_registry: ctx.policy_registry.clone(),