fix: target probes selection

2026-10-13 09:38:31 +03:00 · 2026-09-22 22:17:09 +05:00
parent 9ae4b661ba
commit a7b0abb0ad
3 changed files with 7 additions and 3 deletions
@@ -71,7 +71,11 @@ pub async fn probe_query(
    }

    let (target_probe, eligible_probes) = load_probe_targets(pool, token).await?;
-    let expected_probes = mqtt.online_probe_ids(&eligible_probes).await;
+    let expected_probes = if target_probe.is_some() {
+        eligible_probes
+    } else {
+        mqtt.online_probe_ids(&eligible_probes).await
+    };
    let online_probes = expected_probes.len();
    let expected_probes = expected_probes.into_iter().collect::<HashSet<_>>();