From d73829e118449b43eb929111f6400af031d4bca6 Mon Sep 17 00:00:00 2001 From: Eric Traut Date: Sun, 24 May 2026 03:09:32 -0700 Subject: [PATCH] codex: address PR review feedback (#24321) --- codex-rs/exec/src/lib.rs | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/codex-rs/exec/src/lib.rs b/codex-rs/exec/src/lib.rs index b1aa7f37ff..1c6530fd45 100644 --- a/codex-rs/exec/src/lib.rs +++ b/codex-rs/exec/src/lib.rs @@ -44,12 +44,15 @@ use codex_app_server_protocol::ThreadSource; use codex_app_server_protocol::ThreadSourceKind; use codex_app_server_protocol::ThreadStartParams; use codex_app_server_protocol::ThreadStartResponse; +use codex_app_server_protocol::ThreadTurnsListParams; +use codex_app_server_protocol::ThreadTurnsListResponse; use codex_app_server_protocol::ThreadUnsubscribeParams; use codex_app_server_protocol::ThreadUnsubscribeResponse; use codex_app_server_protocol::Turn; use codex_app_server_protocol::TurnCompletedNotification; use codex_app_server_protocol::TurnInterruptParams; use codex_app_server_protocol::TurnInterruptResponse; +use codex_app_server_protocol::TurnItemsView; use codex_app_server_protocol::TurnStartParams; use codex_app_server_protocol::TurnStartResponse; use codex_app_server_protocol::TurnStartedNotification; @@ -875,24 +878,25 @@ async fn run_exec_session(args: ExecRunArgs) -> anyhow::Result<()> { if active_goal_seen && let Some(running_turn_id) = running_turn_id_from_resume.take() { - let response: ThreadReadResponse = send_request_with_response( + let response: ThreadTurnsListResponse = send_request_with_response( &client, - ClientRequest::ThreadRead { + ClientRequest::ThreadTurnsList { request_id: request_ids.next(), - params: ThreadReadParams { + params: ThreadTurnsListParams { thread_id: primary_thread_id_for_span.clone(), - include_turns: true, + cursor: None, + limit: Some(10), + sort_direction: None, + items_view: Some(TurnItemsView::Full), }, }, - "thread/read", + "thread/turns/list", ) .await .map_err(anyhow::Error::msg)?; if let Some(turn) = response - .thread - .turns + .data .into_iter() - .rev() .find(|turn| turn.id == running_turn_id) { let status = turn.status.clone();