diff --git a/codex-rs/codex-mcp/src/connection_manager.rs b/codex-rs/codex-mcp/src/connection_manager.rs index 3e95d85e3e..d0e2a6a0c1 100644 --- a/codex-rs/codex-mcp/src/connection_manager.rs +++ b/codex-rs/codex-mcp/src/connection_manager.rs @@ -234,11 +234,9 @@ impl McpConnectionManager { join_set.spawn(async move { let outcome = Err(StartupOutcomeError::Failed { error: reason }); let error = match &outcome { - Err(error) => mcp_init_error_display( - server_name.as_str(), - auth_entry.as_ref(), - error, - ), + Err(error) => { + mcp_init_error_display(server_name.as_str(), auth_entry.as_ref(), error) + } Ok(_) => unreachable!("preflight failure cannot start an MCP client"), }; let _ = emit_update( diff --git a/codex-rs/codex-mcp/src/connection_manager_tests.rs b/codex-rs/codex-mcp/src/connection_manager_tests.rs index d712960439..5301571437 100644 --- a/codex-rs/codex-mcp/src/connection_manager_tests.rs +++ b/codex-rs/codex-mcp/src/connection_manager_tests.rs @@ -932,9 +932,11 @@ async fn no_local_runtime_skips_local_stdio_but_keeps_local_http_server() { assert!(!manager.clients.contains_key("stdio")); assert!(manager.clients.contains_key("http")); - assert!(!manager - .wait_for_server_ready("stdio", Duration::from_millis(10)) - .await); + assert!( + !manager + .wait_for_server_ready("stdio", Duration::from_millis(10)) + .await + ); let failures = manager .required_startup_failures(&["stdio".to_string()]) .await;