openai/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-11-12 21:20:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

codex: address PR review feedback (#24321)

Browse Source
This commit is contained in:
Eric Traut
2026-05-24 03:09:32 -07:00
parent 7f3448e1ff
commit d73829e118
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
codex-rs/exec/src/lib.rs
+12 -8
View File
@@ -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();