mirrors/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-04-28 02:11:08 +03:00
Code Issues Packages Projects Releases Wiki Activity

nit 2

Browse Source
This commit is contained in:
jif-oai
2026-02-17 18:23:58 +00:00
parent 2f90b473a3
commit 9aaa6311ef
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
codex-rs/state/src/runtime/memories.rs
View File

@@ -641,7 +641,7 @@ WHERE kind = ? AND job_key = ?
let existing_job = sqlx::query(
r#"
SELECT status, lease_until, retry_at, retry_remaining, input_watermark, last_success_watermark, started_at
SELECT status, lease_until, retry_at, retry_remaining, input_watermark, last_success_watermark, started_at, last_error
FROM jobs
WHERE kind = ? AND job_key = ?
"#,
@@ -669,6 +669,7 @@ WHERE kind = ? AND job_key = ?
let retry_at: Option<i64> = existing_job.try_get("retry_at")?;
let retry_remaining: i64 = existing_job.try_get("retry_remaining")?;
let started_at: Option<i64> = existing_job.try_get("started_at")?;
let last_error: Option<String> = existing_job.try_get("last_error")?;
if retry_remaining <= 0 {
tx.commit().await?;
@@ -684,6 +685,7 @@ WHERE kind = ? AND job_key = ?
return Ok(Phase2JobClaimOutcome::SkippedRunning);
}
if status != "running"
&& last_error.is_none()
&& started_at.is_some_and(|started_at| {
started_at > now.saturating_sub(PHASE2_CLAIM_COOLDOWN_SECONDS)
})