searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2025-04-18 07:57:59 +02:00
Code Issues Releases Wiki Activity

Use TaskKindCannotBeBatched for task deletion, upgrade database and snapshot creation

Browse Source
This commit is contained in:
Louis Dureuil 2025-04-15 14:58:32 +02:00
parent f8ff91ed30
commit 231a027c7d
No known key found for this signature in database
1 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
crates/index-scheduler/src/scheduler/create_batch.rs
View File

@ -454,10 +454,8 @@ impl IndexScheduler {
current_batch.uid = batch_uid; current_batch.uid = batch_uid;
} }
current_batch.processing(&mut tasks); current_batch.processing(&mut tasks);
current_batch.reason(BatchStopReason::TaskCannotBeBatched { current_batch
kind: Kind::UpgradeDatabase, .reason(BatchStopReason::TaskKindCannotBeBatched { kind: Kind::UpgradeDatabase });
id: tasks.first().unwrap().uid,
});
return Ok(Some((Batch::UpgradeDatabase { tasks }, current_batch))); return Ok(Some((Batch::UpgradeDatabase { tasks }, current_batch)));
} }
@ -479,10 +477,8 @@ impl IndexScheduler {
if !to_delete.is_empty() { if !to_delete.is_empty() {
let mut tasks = self.queue.tasks.get_existing_tasks(rtxn, to_delete)?; let mut tasks = self.queue.tasks.get_existing_tasks(rtxn, to_delete)?;
current_batch.processing(&mut tasks); current_batch.processing(&mut tasks);
current_batch.reason(BatchStopReason::TaskCannotBeBatched { current_batch
kind: Kind::TaskDeletion, .reason(BatchStopReason::TaskKindCannotBeBatched { kind: Kind::TaskDeletion });
id: tasks.first().unwrap().uid,
});
return Ok(Some((Batch::TaskDeletions(tasks), current_batch))); return Ok(Some((Batch::TaskDeletions(tasks), current_batch)));
} }
@ -491,10 +487,8 @@ impl IndexScheduler {
if !to_snapshot.is_empty() { if !to_snapshot.is_empty() {
let mut tasks = self.queue.tasks.get_existing_tasks(rtxn, to_snapshot)?; let mut tasks = self.queue.tasks.get_existing_tasks(rtxn, to_snapshot)?;
current_batch.processing(&mut tasks); current_batch.processing(&mut tasks);
current_batch.reason(BatchStopReason::TaskCannotBeBatched { current_batch
kind: Kind::SnapshotCreation, .reason(BatchStopReason::TaskKindCannotBeBatched { kind: Kind::SnapshotCreation });
id: tasks.first().unwrap().uid,
});
return Ok(Some((Batch::SnapshotCreation(tasks), current_batch))); return Ok(Some((Batch::SnapshotCreation(tasks), current_batch)));
} }