diff --git a/codex-rs/core/src/session/turn.rs b/codex-rs/core/src/session/turn.rs index 509811af59..0c688837ed 100644 --- a/codex-rs/core/src/session/turn.rs +++ b/codex-rs/core/src/session/turn.rs @@ -382,7 +382,14 @@ pub(crate) async fn run_turn( if !pending_input.is_empty() { let mut pending_input_iter = pending_input.into_iter(); while let Some(pending_input_item) = pending_input_iter.next() { - match inspect_input_item(&sess, &turn_context, pending_input_item, None).await { + match inspect_input_item( + &sess, + &turn_context, + pending_input_item, + /*original_user_input*/ None, + ) + .await + { InputItemHookDisposition::Accepted(pending_input) => { accepted_pending_input.push(*pending_input); } diff --git a/codex-rs/core/src/tasks/mod.rs b/codex-rs/core/src/tasks/mod.rs index ec5e9ad6c7..0406465360 100644 --- a/codex-rs/core/src/tasks/mod.rs +++ b/codex-rs/core/src/tasks/mod.rs @@ -448,7 +448,14 @@ impl Session { } if !pending_input.is_empty() { for pending_input_item in pending_input { - match inspect_input_item(self, &turn_context, pending_input_item, None).await { + match inspect_input_item( + self, + &turn_context, + pending_input_item, + /*original_user_input*/ None, + ) + .await + { InputItemHookDisposition::Accepted(pending_input) => { record_input_item(self, &turn_context, *pending_input).await; }