From bcc8fd2110916103f9510dc8c502482ee2db8fff Mon Sep 17 00:00:00 2001 From: Mia Date: Sat, 19 Jul 2025 10:58:47 +0100 Subject: [PATCH] fix(consumer): mark the tracker as closed when we've finished spawning threads so that the indexer can auto-exit on crash --- consumer/src/main.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/consumer/src/main.rs b/consumer/src/main.rs index eff3984b..f574f2cc 100644 --- a/consumer/src/main.rs +++ b/consumer/src/main.rs @@ -132,14 +132,13 @@ async fn main() -> eyre::Result<()> { tracker.spawn(index_transport(index_client, idxc_rx)); } - let tc = tracker.clone(); - tracker.spawn(async move { + tokio::spawn(async move { let _ = ctrl_c().await; tracing::info!("stopping consumer"); stop_tx.send(true).unwrap(); - tc.close(); }); + tracker.close(); tracker.wait().await; Ok(()) -- 2.51.2