snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-22 19:46:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve the task batch stopped message

Browse Source
This commit is contained in:
Clément Renault
2025-10-16 16:39:50 +02:00
parent c064737137
commit 8c7e5c094e
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -525,8 +525,10 @@ impl IndexScheduler {
let mut task = let mut task =
self.queue.tasks.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?; self.queue.tasks.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?;
current_batch.processing(Some(&mut task)); current_batch.processing(Some(&mut task));
current_batch current_batch.reason(BatchStopReason::TaskCannotBeBatched {
.reason(BatchStopReason::TaskKindCannotBeBatched { kind: Kind::IndexCompaction }); kind: Kind::IndexCompaction,
id: task_id,
});
let index_uid = let index_uid =
task.index_uid().expect("Compaction task must have an index uid").to_owned(); task.index_uid().expect("Compaction task must have an index uid").to_owned();
return Ok(Some((Batch::IndexCompaction { index_uid, task }, current_batch))); return Ok(Some((Batch::IndexCompaction { index_uid, task }, current_batch)));
@@ -538,7 +540,8 @@ impl IndexScheduler {
let task_id = to_export.iter().next().expect("There must be at least one export task"); let task_id = to_export.iter().next().expect("There must be at least one export task");
let mut task = self.queue.tasks.get_task(rtxn, task_id)?.unwrap(); let mut task = self.queue.tasks.get_task(rtxn, task_id)?.unwrap();
current_batch.processing([&mut task]); current_batch.processing([&mut task]);
current_batch.reason(BatchStopReason::TaskKindCannotBeBatched { kind: Kind::Export }); current_batch
.reason(BatchStopReason::TaskCannotBeBatched { kind: Kind::Export, id: task_id });
return Ok(Some((Batch::Export { task }, current_batch))); return Ok(Some((Batch::Export { task }, current_batch)));
} }