From aabb04b726fc7b46f5da9720b39a23c31de4920b Mon Sep 17 00:00:00 2001 From: Dylan Hurd Date: Tue, 28 Apr 2026 03:11:05 -0700 Subject: [PATCH] Fix log db batch flush flake --- codex-rs/state/src/log_db.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/codex-rs/state/src/log_db.rs b/codex-rs/state/src/log_db.rs index a9da475329a2..6024d6bdaa09 100644 --- a/codex-rs/state/src/log_db.rs +++ b/codex-rs/state/src/log_db.rs @@ -367,6 +367,8 @@ async fn run_inserter( ) { let mut buffer = Vec::with_capacity(config.batch_size); let mut ticker = tokio::time::interval(config.flush_interval); + // Consume the immediate startup tick so entries flush after the interval. + ticker.tick().await; loop { tokio::select! { maybe_command = receiver.recv() => { @@ -645,7 +647,6 @@ mod tests { flush_interval: std::time::Duration::from_secs(60), }, ); - tokio::time::sleep(std::time::Duration::from_millis(10)).await; let guard = tracing_subscriber::registry() .with(