clone/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-04-24 14:45:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

clean

Browse Source
This commit is contained in:
Ahmed Ibrahim
2025-10-22 16:14:20 -07:00
parent 89efcac5a3
commit 838d82e19c
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
codex-rs/core/src/codex.rs
View File

@@ -1966,7 +1966,7 @@ async fn try_run_turn(
Ok(event) => event,
Err(codex_async_utils::CancelErr::Cancelled) => {
info!("Turn aborted");
let processed_items = finalize_turn(output).await?;
let processed_items = output.try_collect().await?;
return Err(CodexErr::TurnAborted {
dangling_artifacts: processed_items,
});
@@ -2086,7 +2086,7 @@ async fn try_run_turn(
let msg = EventMsg::TurnDiff(TurnDiffEvent { unified_diff });
sess.send_event(turn_context.as_ref(), msg).await;
}
let processed_items = finalize_turn(output).await?;
let processed_items = output.try_collect().await?;
return Ok(TurnRunResult {
processed_items,
total_token_usage: token_usage.clone(),
@@ -2123,14 +2123,6 @@ async fn try_run_turn(
}
}
async fn finalize_turn<'a>(
output: FuturesOrdered<BoxFuture<'a, CodexResult<ProcessedResponseItem>>>,
) -> CodexResult<Vec<ProcessedResponseItem>> {
let processed_items = output.try_collect().await?;
Ok(processed_items)
}
async fn handle_non_tool_response_item(
sess: &Session,
turn_context: Arc<TurnContext>,