Skip to content

Commit 9c7fd48

Browse files
authored
refactor: server cleanups (#387)
Signed-off-by: declark1 <44146800+declark1@users.noreply.github.com>
1 parent e3985d5 commit 9c7fd48

File tree

8 files changed

+844
-757
lines changed

8 files changed

+844
-757
lines changed

src/main.rs

+9-2
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ use clap::Parser;
2121
use fms_guardrails_orchestr8::{
2222
args::Args, config::OrchestratorConfig, orchestrator::Orchestrator, server, utils,
2323
};
24+
use tracing::info;
2425

2526
fn main() -> Result<(), anyhow::Error> {
2627
rustls::crypto::aws_lc_rs::default_provider()
@@ -50,15 +51,21 @@ fn main() -> Result<(), anyhow::Error> {
5051
let config = OrchestratorConfig::load(args.config_path).await?;
5152
let orchestrator = Orchestrator::new(config, args.start_up_health_check).await?;
5253

53-
server::run(
54+
let (health_handle, guardrails_handle) = server::run(
5455
http_addr,
5556
health_http_addr,
5657
args.tls_cert_path,
5758
args.tls_key_path,
5859
args.tls_client_ca_cert_path,
5960
orchestrator,
6061
)
61-
.await?;
62+
.await
63+
.unwrap_or_else(|e| panic!("failed to run server: {e}"));
64+
65+
// Await server shutdown
66+
let _ = tokio::join!(health_handle, guardrails_handle);
67+
info!("shutdown complete");
68+
6269
Ok(trace_shutdown()?)
6370
})
6471
}

0 commit comments

Comments
 (0)