From da9c4655c3658ba0ca6420ea54d06ce7c84af793 Mon Sep 17 00:00:00 2001 From: OlivierDehaene <23298448+OlivierDehaene@users.noreply.github.com> Date: Sat, 1 Jul 2023 18:44:43 +0200 Subject: [PATCH] fix launcher --- launcher/src/main.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/launcher/src/main.rs b/launcher/src/main.rs index 30abe88a..5b5cb45e 100644 --- a/launcher/src/main.rs +++ b/launcher/src/main.rs @@ -1040,14 +1040,18 @@ fn main() -> Result<(), LauncherError> { return Ok(()); } - let mut webserver = spawn_webserver(args, shutdown.clone(), &shutdown_receiver)?; + let mut webserver = + spawn_webserver(args, shutdown.clone(), &shutdown_receiver).map_err(|err| { + shutdown_shards(shutdown.clone(), &shutdown_receiver); + err + })?; // Default exit code let mut exit_code = Ok(()); while running.load(Ordering::SeqCst) { if let Ok(ShardStatus::Failed((rank, err))) = status_receiver.try_recv() { - tracing::error!("Shard {rank} failed to start"); + tracing::error!("Shard {rank} crashed"); if let Some(err) = err { tracing::error!("{err}"); }