clone/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-02-01 22:47:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Guard interrupted flag for late responses

Browse Source
This commit is contained in:
Charles Cunningham
2026-01-31 20:44:31 -08:00
parent 8e5ca2d1f2
commit 84bbabd29b
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1663,10 +1663,6 @@ impl Session {
_call_id: Option<String>,
response: RequestUserInputResponse,
) {
if response.interrupted {
// An interrupted request_user_input should end the turn without a follow-up request.
self.mark_request_user_input_interrupted().await;
}
let entry = {
let mut active = self.active_turn.lock().await;
match active.as_mut() {
@@ -1680,6 +1676,11 @@ impl Session {
match entry {
Some(tx_response) => {
if response.interrupted {
// An interrupted request_user_input should end the turn without a follow-up
// request; only mark the active turn when the response is still pending.
self.mark_request_user_input_interrupted().await;
}
tx_response.send(response).ok();
}
None => {