diff --git a/codex-rs/core/src/session/mod.rs b/codex-rs/core/src/session/mod.rs index f617f59056..4f960b3ee2 100644 --- a/codex-rs/core/src/session/mod.rs +++ b/codex-rs/core/src/session/mod.rs @@ -358,6 +358,8 @@ use codex_protocol::protocol::ThreadMemoryMode; use codex_protocol::protocol::TokenCountEvent; use codex_protocol::protocol::TokenUsage; use codex_protocol::protocol::TokenUsageInfo; +#[cfg(test)] +use codex_protocol::protocol::TurnAbortReason; use codex_protocol::protocol::WarningEvent; use codex_protocol::user_input::UserInput; use codex_tools::ToolEnvironmentMode; diff --git a/codex-rs/core/src/tasks/mod.rs b/codex-rs/core/src/tasks/mod.rs index 08cc8b29ba..2de8c5f942 100644 --- a/codex-rs/core/src/tasks/mod.rs +++ b/codex-rs/core/src/tasks/mod.rs @@ -564,15 +564,6 @@ impl Session { } } - pub(crate) async fn abort_turn_if_active( - self: &Arc, - turn_id: &str, - reason: TurnAbortReason, - ) -> bool { - self.abort_turn_if_active_with(turn_id, TaskAbort::from_turn_abort_reason(reason)) - .await - } - pub(crate) async fn abort_turn_if_active_interrupted( self: &Arc, turn_id: &str,