Skip to content

Commit 26c66f3

Browse files
authored
fix: flaky (#15869)
1 parent 01fa4f0 commit 26c66f3

File tree

1 file changed

+13
-3
lines changed

1 file changed

+13
-3
lines changed

codex-rs/core/tests/suite/unified_exec.rs

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1209,14 +1209,24 @@ async fn unified_exec_emits_one_begin_and_one_end_event() -> Result<()> {
12091209

12101210
let mut begin_events = Vec::new();
12111211
let mut end_events = Vec::new();
1212+
let mut task_completed = false;
12121213
loop {
12131214
let event_msg = wait_for_event(&codex, |_| true).await;
12141215
match event_msg {
1215-
EventMsg::ExecCommandBegin(event) => begin_events.push(event),
1216-
EventMsg::ExecCommandEnd(event) => end_events.push(event),
1217-
EventMsg::TurnComplete(_) => break,
1216+
EventMsg::ExecCommandBegin(event) if event.call_id == open_call_id => {
1217+
begin_events.push(event);
1218+
}
1219+
EventMsg::ExecCommandEnd(event) if event.call_id == open_call_id => {
1220+
end_events.push(event);
1221+
}
1222+
EventMsg::TurnComplete(_) => {
1223+
task_completed = true;
1224+
}
12181225
_ => {}
12191226
}
1227+
if task_completed && !end_events.is_empty() {
1228+
break;
1229+
}
12201230
}
12211231

12221232
assert_eq!(

0 commit comments

Comments
 (0)