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

codex: address PR review feedback (#16282)

Browse Source
This commit is contained in:
Eric Traut
2026-03-31 17:04:45 -06:00
parent 24b097484d
commit c8a5fb70b7
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2703,23 +2703,22 @@ impl Session {
}
pub(crate) async fn maybe_start_pending_job(self: &Arc<Self>) {
let has_pending_turn_inputs = self.has_queued_response_items_for_next_turn().await
|| self.has_trigger_turn_mailbox_items().await;
let Some(ClaimedJob {
job,
context,
deleted_run_once_job,
}) = ({
let mut job_start_in_progress = self.job_start_in_progress.lock().await;
let has_pending_turn_inputs = self.has_queued_response_items_for_next_turn().await
|| self.has_trigger_turn_mailbox_items().await;
if *job_start_in_progress
|| self.active_turn.lock().await.is_some()
|| has_pending_turn_inputs
{
let mut active_turn = self.active_turn.lock().await;
if *job_start_in_progress || active_turn.is_some() || has_pending_turn_inputs {
None
} else {
let claimed = self.jobs.lock().await.claim_next_job(Utc::now());
if claimed.is_some() {
*job_start_in_progress = true;
*active_turn = Some(ActiveTurn::default());
}
claimed
}