From 8c7e5c094e3ee54610953a1f982ddaa07e5beedf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cl=C3=A9ment=20Renault?= Date: Thu, 16 Oct 2025 16:39:50 +0200 Subject: [PATCH] Improve the task batch stopped message --- crates/index-scheduler/src/scheduler/create_batch.rs | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/crates/index-scheduler/src/scheduler/create_batch.rs b/crates/index-scheduler/src/scheduler/create_batch.rs index d711a78c2..24a2340cb 100644 --- a/crates/index-scheduler/src/scheduler/create_batch.rs +++ b/crates/index-scheduler/src/scheduler/create_batch.rs @@ -525,8 +525,10 @@ impl IndexScheduler { let mut task = self.queue.tasks.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?; current_batch.processing(Some(&mut task)); - current_batch - .reason(BatchStopReason::TaskKindCannotBeBatched { kind: Kind::IndexCompaction }); + current_batch.reason(BatchStopReason::TaskCannotBeBatched { + kind: Kind::IndexCompaction, + id: task_id, + }); let index_uid = task.index_uid().expect("Compaction task must have an index uid").to_owned(); 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 mut task = self.queue.tasks.get_task(rtxn, task_id)?.unwrap(); 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))); }