feat: backfill async again (#10894)
This commit is contained in:
parent
1020872eca
commit
3800173459
2 changed files with 9 additions and 3 deletions
|
|
@ -65,9 +65,15 @@ pub(crate) async fn init_if_enabled(
|
|||
}
|
||||
};
|
||||
if backfill_state.status != codex_state::BackfillStatus::Complete {
|
||||
metadata::backfill_sessions(runtime.as_ref(), config, otel).await;
|
||||
let runtime_for_backfill = runtime.clone();
|
||||
let config = config.clone();
|
||||
let otel = otel.cloned();
|
||||
tokio::spawn(async move {
|
||||
metadata::backfill_sessions(runtime_for_backfill.as_ref(), &config, otel.as_ref())
|
||||
.await;
|
||||
});
|
||||
}
|
||||
require_backfill_complete(runtime, config.codex_home.as_path()).await
|
||||
Some(runtime)
|
||||
}
|
||||
|
||||
/// Get the DB if the feature is enabled and the DB exists.
|
||||
|
|
|
|||
|
|
@ -38,7 +38,7 @@ use std::time::Duration;
|
|||
use tracing::warn;
|
||||
|
||||
pub const STATE_DB_FILENAME: &str = "state";
|
||||
pub const STATE_DB_VERSION: u32 = 3;
|
||||
pub const STATE_DB_VERSION: u32 = 4;
|
||||
|
||||
const METRIC_DB_INIT: &str = "codex.db.init";
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue