snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-10 21:56:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

change the details of the tasks

Browse Source
This commit is contained in:
Tamo
2025-08-11 18:28:00 +02:00
parent a904ce109a
commit 4068c58417
102 changed files with 300 additions and 320 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
crates/index-scheduler/src/scheduler/process_batch.rs
View File

@@ -240,23 +240,19 @@ impl IndexScheduler {
// Handle rename if new_index_uid is provided
let final_index_uid = if let Some(new_uid) = &new_index_uid {
index.set_updated_at(&mut index_wtxn, &OffsetDateTime::now_utc())?;
if new_uid != &index_uid {
index.set_updated_at(&mut index_wtxn, &OffsetDateTime::now_utc())?;
let mut wtxn = self.env.write_txn()?;
let mut wtxn = self.env.write_txn()?;
self.apply_index_swap(
&mut wtxn, &progress, task.uid, &index_uid, new_uid, true,
)?;
wtxn.commit()?;
// Rename the index
self.index_mapper.rename(&mut wtxn, &index_uid, new_uid)?;
// Update the task index mappings
let old_tasks =
self.queue.tasks.index_tasks(&wtxn, &index_uid).unwrap_or_default();
self.queue.tasks.update_index(&mut wtxn, new_uid, |bm| {
*bm |= &old_tasks;
})?;
self.queue.tasks.update_index(&mut wtxn, &index_uid, |bm| bm.clear())?;
wtxn.commit()?;
new_uid.clone()
new_uid.clone()
} else {
new_uid.clone()
}
} else {
index_uid.clone()
};
@@ -287,7 +283,7 @@ impl IndexScheduler {
task.status = Status::Succeeded;
task.details = Some(Details::IndexInfo {
primary_key: primary_key.clone(),
new_uid: new_index_uid.clone(),
uid: new_index_uid.clone(),
});
// if the update processed successfully, we're going to store the new