diff --git a/src/rust/lqos_bakery/src/lib.rs b/src/rust/lqos_bakery/src/lib.rs index 1337fe6f..0a13a619 100644 --- a/src/rust/lqos_bakery/src/lib.rs +++ b/src/rust/lqos_bakery/src/lib.rs @@ -703,7 +703,7 @@ fn bakery_main(rx: Receiver, tx: Sender) { .build(); if let Ok(rt) = rt { let stale_to_delete = stale.clone(); - let _ = rt.block_on(async move { + rt.block_on(async move { if let Ok(mut bus) = LibreqosBusClient::new().await { // chunk operations to keep request sizes reasonable const CHUNK: usize = 512; diff --git a/src/rust/lqosd/src/main.rs b/src/rust/lqosd/src/main.rs index f56e11e7..d385c724 100644 --- a/src/rust/lqosd/src/main.rs +++ b/src/rust/lqosd/src/main.rs @@ -239,7 +239,7 @@ fn main() -> Result<()> { } else { info!("Insight client started successfully"); } - let _blackboard_tx = blackboard::start_blackboard(); + blackboard::start_blackboard(); start_remote_commands(); let flow_tx = setup_netflow_tracker()?; let _ = throughput_tracker::flow_data::setup_flow_analysis();