diff --git a/services/monitoring_service/src/prometheus_client.rs b/services/monitoring_service/src/prometheus_client.rs
index 6c7eb4938..333c3eb40 100644
--- a/services/monitoring_service/src/prometheus_client.rs
+++ b/services/monitoring_service/src/prometheus_client.rs
@@ -89,10 +89,10 @@ impl PrometheusClient {
         Ok(parse_samples(results))
     }
 
-    /// Fetch active K8s training job count
+    /// Fetch active training worker count (covers both K8s Jobs and CI runner pods)
     pub async fn fetch_active_jobs(&self) -> Result<u32> {
         let results = self
-            .query(r#"kube_job_status_active{namespace="foxhunt",job_name=~"training-.*"}"#)
+            .query("foxhunt_training_active_workers")
             .await?;
         let count: f64 = results
             .iter()