mirror of
https://github.com/openai/codex.git
synced 2026-11-12 21:20:34 +00:00
enqueue in session loop
This commit is contained in:
@@ -1932,6 +1932,7 @@ async fn try_run_sampling_request(
|
||||
)
|
||||
.await
|
||||
{
|
||||
crate::guardian::enqueue_proactive_guardian_trunk_sync(&sess, &turn_context);
|
||||
continue;
|
||||
}
|
||||
|
||||
@@ -1968,6 +1969,7 @@ async fn try_run_sampling_request(
|
||||
Ok(output_result) => output_result,
|
||||
Err(err) => break Err(err),
|
||||
};
|
||||
crate::guardian::enqueue_proactive_guardian_trunk_sync(&sess, &turn_context);
|
||||
if let Some(tool_future) = output_result.tool_future {
|
||||
in_flight.push_back(tool_future);
|
||||
}
|
||||
|
||||
@@ -342,8 +342,6 @@ pub(crate) async fn handle_output_item_done(
|
||||
}
|
||||
}
|
||||
|
||||
crate::guardian::enqueue_proactive_guardian_trunk_sync(&ctx.sess, &ctx.turn_context);
|
||||
|
||||
Ok(output)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user