diff --git a/codex-rs/core/tests/common/responses.rs b/codex-rs/core/tests/common/responses.rs index 171ec36756..2dcfd5203d 100644 --- a/codex-rs/core/tests/common/responses.rs +++ b/codex-rs/core/tests/common/responses.rs @@ -541,7 +541,14 @@ impl WebSocketTestServer { pub async fn shutdown(self) { let _ = self.shutdown.send(()); - let _ = self.task.await; + let mut task = self.task; + if tokio::time::timeout(Duration::from_secs(10), &mut task) + .await + .is_err() + { + task.abort(); + let _ = task.await; + } } }