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

codex: fix CI failure on PR #16989

Browse Source
This commit is contained in:
Eric Traut
2026-04-08 22:25:35 -07:00
parent 7615a2a93a
commit ba96d37df4
1 changed files with 22 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
codex-rs/state/src/runtime.rs
+22 -11
View File
@@ -69,6 +69,7 @@ pub use remote_control::RemoteControlEnrollmentRecord;
// metadata, rather than the exact sum of all persisted SQLite column bytes.
const LOG_PARTITION_SIZE_LIMIT_BYTES: i64 = 10 * 1024 * 1024;
const LOG_PARTITION_ROW_LIMIT: i64 = 1_000;
const CHECKPOINT_WAL_BUSY_MAX_ATTEMPTS: usize = 10;
#[derive(Clone)]
pub struct StateRuntime {
@@ -149,18 +150,28 @@ impl StateRuntime {
}
async fn checkpoint_wal_pool(pool: &SqlitePool, name: &str) -> anyhow::Result<()> {
let row = sqlx::query("PRAGMA wal_checkpoint(TRUNCATE)")
.fetch_one(pool)
.await?;
let busy: i64 = row.try_get(0)?;
let log_pages: i64 = row.try_get(1)?;
let checkpointed_pages: i64 = row.try_get(2)?;
if busy != 0 {
anyhow::bail!(
"{name} WAL checkpoint was busy: {checkpointed_pages}/{log_pages} pages checkpointed"
);
let mut last_busy_result = None;
for attempt in 1..=CHECKPOINT_WAL_BUSY_MAX_ATTEMPTS {
let row = sqlx::query("PRAGMA wal_checkpoint(TRUNCATE)")
.fetch_one(pool)
.await?;
let busy: i64 = row.try_get(0)?;
let log_pages: i64 = row.try_get(1)?;
let checkpointed_pages: i64 = row.try_get(2)?;
if busy == 0 {
return Ok(());
}
last_busy_result = Some((checkpointed_pages, log_pages));
if attempt < CHECKPOINT_WAL_BUSY_MAX_ATTEMPTS {
tokio::time::sleep(Duration::from_millis(50)).await;
}
}
Ok(())
let (checkpointed_pages, log_pages) = last_busy_result.unwrap_or((0, 0));
anyhow::bail!(
"{name} WAL checkpoint was busy: {checkpointed_pages}/{log_pages} pages checkpointed"
)
}
fn base_sqlite_options(path: &Path) -> SqliteConnectOptions {