From f81b51d7d2e6c70092ea9179afe5c5b02263ddc2 Mon Sep 17 00:00:00 2001 From: Nicolas Patry Date: Wed, 19 Mar 2025 15:04:28 +0100 Subject: [PATCH] Fmt. --- launcher/src/main.rs | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/launcher/src/main.rs b/launcher/src/main.rs index 89815781d..250613812 100644 --- a/launcher/src/main.rs +++ b/launcher/src/main.rs @@ -1211,7 +1211,12 @@ fn shard_manager( // We received a shutdown signal if shutdown.load(Ordering::SeqCst) { - terminate("shard", p, Duration::from_secs(graceful_termination_timeout)).unwrap(); + terminate( + "shard", + p, + Duration::from_secs(graceful_termination_timeout), + ) + .unwrap(); return; } @@ -1550,7 +1555,7 @@ fn spawn_shards( status_receiver: &mpsc::Receiver, status_sender: mpsc::Sender, running: Arc, - graceful_termination_timeout: u64 + graceful_termination_timeout: u64, ) -> Result<(), LauncherError> { // Start shard processes for rank in 0..num_shard { @@ -2317,7 +2322,12 @@ fn main() -> Result<(), LauncherError> { } // Graceful termination - terminate("webserver", webserver, Duration::from_secs(graceful_termination_timeout)).unwrap(); + terminate( + "webserver", + webserver, + Duration::from_secs(graceful_termination_timeout), + ) + .unwrap(); shutdown_shards(shutdown, &shutdown_receiver); exit_code