From 2bf0d73c8b151ab3ef80a783b6c7e75ad046a9d4 Mon Sep 17 00:00:00 2001 From: damocles Date: Tue, 11 Aug 2026 22:48:25 +0200 Subject: [PATCH] hive-c0re: drop needless async from pause_many (clippy pedantic) --- hive-c0re/src/job_queue/power.rs | 9 ++++----- hive-c0re/src/server.rs | 3 +-- 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/hive-c0re/src/job_queue/power.rs b/hive-c0re/src/job_queue/power.rs index a8adc49c..8e286896 100644 --- a/hive-c0re/src/job_queue/power.rs +++ b/hive-c0re/src/job_queue/power.rs @@ -342,14 +342,13 @@ pub(crate) fn pause_nodes(builder: &JobBuilder, agents: &[String]) -> Vec, - agents: &[String], -) -> anyhow::Result> { +pub fn pause_many(coord: &Arc, agents: &[String]) -> anyhow::Result> { let targets: Vec = agents.to_vec(); let ids = coord.job_queue.insert_job(|b| pause_nodes(b, &targets))?; coord.emit_rebuild_queue_snapshot(); diff --git a/hive-c0re/src/server.rs b/hive-c0re/src/server.rs index f1a13a29..277483eb 100644 --- a/hive-c0re/src/server.rs +++ b/hive-c0re/src/server.rs @@ -358,8 +358,7 @@ async fn handle_set_paused( coord.rescan_containers_and_emit().await; return HostResponse::success(); } - match crate::job_queue::power::pause_many(coord, std::slice::from_ref(&name.to_string())).await - { + match crate::job_queue::power::pause_many(coord, std::slice::from_ref(&name.to_string())) { Ok(ids) => { tracing::info!(%name, "agent pause queued"); HostResponse::queued(ids.into_iter().map(hive_jobq::NodeId::get).collect())