diff --git a/codex-rs/core/tests/common/responses.rs b/codex-rs/core/tests/common/responses.rs index 07aaff5aab..511c0b5b03 100644 --- a/codex-rs/core/tests/common/responses.rs +++ b/codex-rs/core/tests/common/responses.rs @@ -98,7 +98,8 @@ impl ResponsesRequest { /// If present, returns the `output` string of the `function_call_output` /// entry matching `call_id` in this request's `input`. pub fn function_call_output_text(&self, call_id: &str) -> Option { - let item = self.input().iter().find(|item| { + let binding = self.input(); + let item = binding.iter().find(|item| { item.get("type").and_then(Value::as_str) == Some("function_call_output") && item.get("call_id").and_then(Value::as_str) == Some(call_id) })?; diff --git a/codex-rs/core/tests/suite/abort_tasks.rs b/codex-rs/core/tests/suite/abort_tasks.rs index 6be8a98a33..c9d595088a 100644 --- a/codex-rs/core/tests/suite/abort_tasks.rs +++ b/codex-rs/core/tests/suite/abort_tasks.rs @@ -105,7 +105,7 @@ async fn interrupt_tool_records_history_entries() { let fixture = test_codex().build(&server).await.unwrap(); let codex = Arc::clone(&fixture.codex); - let wait_timeout = Duration::from_secs(0.1); + let wait_timeout = Duration::from_millis(100); codex .submit(Op::UserInput {