diff --git a/crates/agent/src/controllers/handler.rs b/crates/agent/src/controllers/handler.rs index 7905ecf036..e681875ab3 100644 --- a/crates/agent/src/controllers/handler.rs +++ b/crates/agent/src/controllers/handler.rs @@ -1,6 +1,5 @@ use agent_sql::controllers::{dequeue, update}; use anyhow::Context; -use chrono::{DateTime, Utc}; use crate::{ controlplane::{ControlPlane, PGControlPlane}, diff --git a/crates/agent/src/controllers/mod.rs b/crates/agent/src/controllers/mod.rs index 1d1dd03bf3..705bf02976 100644 --- a/crates/agent/src/controllers/mod.rs +++ b/crates/agent/src/controllers/mod.rs @@ -444,6 +444,7 @@ impl Status { /// Selects the smallest next run from among the arguments, returning `None` /// only if all `next_runs` are `None`. +#[allow(dead_code)] fn reduce_next_run(next_runs: &[Option]) -> Option { let mut min: Option = None; for next_run in next_runs { diff --git a/crates/agent/src/jobs.rs b/crates/agent/src/jobs.rs index 7a4e9e54e3..2f0070217e 100644 --- a/crates/agent/src/jobs.rs +++ b/crates/agent/src/jobs.rs @@ -181,6 +181,7 @@ where Ok(status) } +#[allow(dead_code)] async fn read_stdout(mut reader: async_process::ChildStdio) -> Result, Error> { let mut buffer = Vec::new(); let _ = tokio::io::copy(&mut reader, &mut buffer)