searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2025-05-25 09:03:59 +02:00
Code Issues Releases Wiki Activity

Roll back index scheduler version first

Browse Source
This commit is contained in:
Louis Dureuil 2025-04-29 16:04:53 +02:00
parent 20d0aa499a
commit 1542ff30ae
No known key found for this signature in database
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
crates/index-scheduler/src/scheduler/process_upgrade/mod.rs
View File

@ -53,6 +53,12 @@ impl IndexScheduler {
} }
pub fn process_rollback(&self, db_version: (u32, u32, u32), progress: &Progress) -> Result<()> { pub fn process_rollback(&self, db_version: (u32, u32, u32), progress: &Progress) -> Result<()> {
let mut wtxn = self.env.write_txn()?;
tracing::info!(?db_version, "roll back index scheduler version");
self.version.set_version(&mut wtxn, db_version)?;
let db_path = self.scheduler.version_file_path.parent().unwrap();
wtxn.commit()?;
let indexes = self.index_names()?; let indexes = self.index_names()?;
tracing::info!("roll backing all indexes"); tracing::info!("roll backing all indexes");
@ -71,11 +77,6 @@ impl IndexScheduler {
} }
} }
let mut wtxn = self.env.write_txn()?;
tracing::info!(?db_version, "roll back index scheduler version");
self.version.set_version(&mut wtxn, db_version)?;
let db_path = self.scheduler.version_file_path.parent().unwrap();
wtxn.commit()?;
tracing::info!(?db_path, ?db_version, "roll back version file"); tracing::info!(?db_path, ?db_version, "roll back version file");
meilisearch_types::versioning::create_version_file( meilisearch_types::versioning::create_version_file(
db_path, db_path,