Merge b5bea0cf56 into 94fb55bb6f

crates/index-scheduler/src/batch.rs

@@ -24,7 +24,6 @@ use std::fs::{self, File};
 use std::io::BufWriter;
 
 use dump::IndexMetadata;
-use meilisearch_types::batches::BatchId;
 use meilisearch_types::error::Code;
 use meilisearch_types::heed::{RoTxn, RwTxn};
 use meilisearch_types::milli::documents::{obkv_to_object, DocumentsBatchReader};
@@ -45,7 +44,7 @@ use time::OffsetDateTime;
 use uuid::Uuid;
 
 use crate::autobatcher::{self, BatchKind};
-use crate::utils::{self, swap_index_uid_in_task};
+use crate::utils::{self, swap_index_uid_in_task, ProcessingBatch};
 use crate::{Error, IndexScheduler, MustStopProcessing, ProcessingTasks, Result, TaskId};
 
 /// Represents a combination of tasks that can all be processed at the same time.
@@ -280,22 +279,24 @@ impl IndexScheduler {
         rtxn: &RoTxn,
         index_uid: String,
         batch: BatchKind,
-        batch_id: BatchId,
+        current_batch: &mut ProcessingBatch,
         must_create_index: bool,
     ) -> Result<Option<Batch>> {
         match batch {
             BatchKind::DocumentClear { ids } => Ok(Some(Batch::IndexOperation {
                 op: IndexOperation::DocumentClear {
-                    tasks: self.get_existing_tasks_with_batch_id(rtxn, batch_id, ids)?,
+                    tasks: self.get_existing_tasks_with_processing_batch(
+                        rtxn,
+                        current_batch,
+                        ids,
+                    )?,
                     index_uid,
                 },
                 must_create_index,
             })),
             BatchKind::DocumentEdition { id } => {
-                let task = self
+                let mut task = self.get_task(rtxn, id)?.ok_or(Error::CorruptedTaskQueue)?;
-                    .get_task(rtxn, id)?
+                current_batch.processing(Some(&mut task));
-                    .ok_or(Error::CorruptedTaskQueue)?
-                    .with_batch_id(batch_id);
                 match &task.kind {
                     KindWithContent::DocumentEdition { index_uid, .. } => {
                         Ok(Some(Batch::IndexOperation {
@@ -310,7 +311,11 @@ impl IndexScheduler {
                 }
             }
             BatchKind::DocumentOperation { method, operation_ids, .. } => {
-                let tasks = self.get_existing_tasks_with_batch_id(rtxn, batch_id, operation_ids)?;
+                let tasks = self.get_existing_tasks_with_processing_batch(
+                    rtxn,
+                    current_batch,
+                    operation_ids,
+                )?;
                 let primary_key = tasks
                     .iter()
                     .find_map(|task| match task.kind {
@@ -357,7 +362,11 @@ impl IndexScheduler {
                 }))
             }
             BatchKind::DocumentDeletion { deletion_ids, includes_by_filter: _ } => {
-                let tasks = self.get_existing_tasks_with_batch_id(rtxn, batch_id, deletion_ids)?;
+                let tasks = self.get_existing_tasks_with_processing_batch(
+                    rtxn,
+                    current_batch,
+                    deletion_ids,
+                )?;
 
                 Ok(Some(Batch::IndexOperation {
                     op: IndexOperation::DocumentDeletion { index_uid, tasks },
@@ -365,7 +374,11 @@ impl IndexScheduler {
                 }))
             }
             BatchKind::Settings { settings_ids, .. } => {
-                let tasks = self.get_existing_tasks_with_batch_id(rtxn, batch_id, settings_ids)?;
+                let tasks = self.get_existing_tasks_with_processing_batch(
+                    rtxn,
+                    current_batch,
+                    settings_ids,
+                )?;
 
                 let mut settings = Vec::new();
                 for task in &tasks {
@@ -388,7 +401,7 @@ impl IndexScheduler {
                         rtxn,
                         index_uid,
                         BatchKind::Settings { settings_ids, allow_index_creation },
-                        batch_id,
+                        current_batch,
                         must_create_index,
                     )?
                     .unwrap()
@@ -404,7 +417,7 @@ impl IndexScheduler {
                         rtxn,
                         index_uid,
                         BatchKind::DocumentClear { ids: other },
-                        batch_id,
+                        current_batch,
                         must_create_index,
                     )?
                     .unwrap()
@@ -437,7 +450,7 @@ impl IndexScheduler {
                     rtxn,
                     index_uid.clone(),
                     BatchKind::Settings { settings_ids, allow_index_creation },
-                    batch_id,
+                    current_batch,
                     must_create_index,
                 )?;
 
@@ -450,7 +463,7 @@ impl IndexScheduler {
                         primary_key,
                         operation_ids,
                     },
-                    batch_id,
+                    current_batch,
                     must_create_index,
                 )?;
 
@@ -488,10 +501,8 @@ impl IndexScheduler {
                 }
             }
             BatchKind::IndexCreation { id } => {
-                let task = self
+                let mut task = self.get_task(rtxn, id)?.ok_or(Error::CorruptedTaskQueue)?;
-                    .get_task(rtxn, id)?
+                current_batch.processing(Some(&mut task));
-                    .ok_or(Error::CorruptedTaskQueue)?
-                    .with_batch_id(batch_id);
                 let (index_uid, primary_key) = match &task.kind {
                     KindWithContent::IndexCreation { index_uid, primary_key } => {
                         (index_uid.clone(), primary_key.clone())
@@ -501,10 +512,8 @@ impl IndexScheduler {
                 Ok(Some(Batch::IndexCreation { index_uid, primary_key, task }))
             }
             BatchKind::IndexUpdate { id } => {
-                let task = self
+                let mut task = self.get_task(rtxn, id)?.ok_or(Error::CorruptedTaskQueue)?;
-                    .get_task(rtxn, id)?
+                current_batch.processing(Some(&mut task));
-                    .ok_or(Error::CorruptedTaskQueue)?
-                    .with_batch_id(batch_id);
                 let primary_key = match &task.kind {
                     KindWithContent::IndexUpdate { primary_key, .. } => primary_key.clone(),
                     _ => unreachable!(),
@@ -514,13 +523,11 @@ impl IndexScheduler {
             BatchKind::IndexDeletion { ids } => Ok(Some(Batch::IndexDeletion {
                 index_uid,
                 index_has_been_created: must_create_index,
-                tasks: self.get_existing_tasks_with_batch_id(rtxn, batch_id, ids)?,
+                tasks: self.get_existing_tasks_with_processing_batch(rtxn, current_batch, ids)?,
             })),
             BatchKind::IndexSwap { id } => {
-                let task = self
+                let mut task = self.get_task(rtxn, id)?.ok_or(Error::CorruptedTaskQueue)?;
-                    .get_task(rtxn, id)?
+                current_batch.processing(Some(&mut task));
-                    .ok_or(Error::CorruptedTaskQueue)?
-                    .with_batch_id(batch_id);
                 Ok(Some(Batch::IndexSwap { task }))
             }
         }
@@ -533,11 +540,16 @@ impl IndexScheduler {
     /// 4. We get the *next* dump to process.
     /// 5. We get the *next* tasks to process for a specific index.
     #[tracing::instrument(level = "trace", skip(self, rtxn), target = "indexing::scheduler")]
-    pub(crate) fn create_next_batch(&self, rtxn: &RoTxn) -> Result<Option<(Batch, BatchId)>> {
+    pub(crate) fn create_next_batch(
+        &self,
+        rtxn: &RoTxn,
+    ) -> Result<Option<(Batch, ProcessingBatch)>> {
         #[cfg(test)]
         self.maybe_fail(crate::tests::FailureLocation::InsideCreateBatch)?;
 
         let batch_id = self.next_batch_id(rtxn)?;
+        let mut current_batch = ProcessingBatch::new(batch_id);
+
         let enqueued = &self.get_status(rtxn, Status::Enqueued)?;
         let to_cancel = self.get_kind(rtxn, Kind::TaskCancelation)? & enqueued;
 
@@ -547,63 +559,51 @@ impl IndexScheduler {
             // We must *not* reset the processing tasks before calling this method.
             // Displaying the `batch_id` would make a strange error message since this task cancelation is going to
             // replace the canceled batch. It's better to avoid mentioning it in the error message.
-            let ProcessingTasks { started_at, batch_id: _, processing } =
+            let ProcessingTasks { batch: previous_batch, processing } =
                 &*self.processing_tasks.read().unwrap();
+            let mut task = self.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?;
+            current_batch.processing(Some(&mut task));
             return Ok(Some((
                 Batch::TaskCancelation {
-                    task: self
+                    task,
-                        .get_task(rtxn, task_id)?
+                    // We should never be in a case where we don't have a previous_batch, but let's not crash if it happens
-                        .ok_or(Error::CorruptedTaskQueue)?
+                    previous_started_at: previous_batch
-                        .with_batch_id(batch_id),
+                        .as_ref()
-                    previous_started_at: *started_at,
+                        .map_or_else(OffsetDateTime::now_utc, |batch| batch.started_at),
                     previous_processing_tasks: processing.clone(),
                 },
-                batch_id,
+                current_batch,
             )));
         }
 
         // 2. we get the next task to delete
         let to_delete = self.get_kind(rtxn, Kind::TaskDeletion)? & enqueued;
         if !to_delete.is_empty() {
-            let tasks = self
+            let mut tasks = self.get_existing_tasks(rtxn, to_delete)?;
-                .get_existing_tasks(rtxn, to_delete)?
+            current_batch.processing(&mut tasks);
-                .into_iter()
+            return Ok(Some((Batch::TaskDeletions(tasks), current_batch)));
-                .map(|task| task.with_batch_id(batch_id))
-                .collect();
-            return Ok(Some((Batch::TaskDeletions(tasks), batch_id)));
         }
 
         // 3. we batch the snapshot.
         let to_snapshot = self.get_kind(rtxn, Kind::SnapshotCreation)? & enqueued;
         if !to_snapshot.is_empty() {
-            return Ok(Some((
+            let mut tasks = self.get_existing_tasks(rtxn, to_snapshot)?;
-                Batch::SnapshotCreation(
+            current_batch.processing(&mut tasks);
-                    self.get_existing_tasks(rtxn, to_snapshot)?
+            return Ok(Some((Batch::SnapshotCreation(tasks), current_batch)));
-                        .into_iter()
-                        .map(|task| task.with_batch_id(batch_id))
-                        .collect(),
-                ),
-                batch_id,
-            )));
         }
 
         // 4. we batch the dumps.
         let to_dump = self.get_kind(rtxn, Kind::DumpCreation)? & enqueued;
         if let Some(to_dump) = to_dump.min() {
-            return Ok(Some((
+            let mut task = self.get_task(rtxn, to_dump)?.ok_or(Error::CorruptedTaskQueue)?;
-                Batch::Dump(
+            current_batch.processing(Some(&mut task));
-                    self.get_task(rtxn, to_dump)?
+            return Ok(Some((Batch::Dump(task), current_batch)));
-                        .ok_or(Error::CorruptedTaskQueue)?
-                        .with_batch_id(batch_id),
-                ),
-                batch_id,
-            )));
         }
 
         // 5. We make a batch from the unprioritised tasks. Start by taking the next enqueued task.
         let task_id = if let Some(task_id) = enqueued.min() { task_id } else { return Ok(None) };
-        let task =
+        let mut task = self.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?;
-            self.get_task(rtxn, task_id)?.ok_or(Error::CorruptedTaskQueue)?.with_batch_id(batch_id);
+        current_batch.processing(Some(&mut task));
 
         // If the task is not associated with any index, verify that it is an index swap and
         // create the batch directly. Otherwise, get the index name associated with the task
@@ -613,7 +613,7 @@ impl IndexScheduler {
             index_name
         } else {
             assert!(matches!(&task.kind, KindWithContent::IndexSwap { swaps } if swaps.is_empty()));
-            return Ok(Some((Batch::IndexSwap { task }, batch_id)));
+            return Ok(Some((Batch::IndexSwap { task }, current_batch)));
         };
 
         let index_already_exists = self.index_mapper.exists(rtxn, index_name)?;
@@ -649,10 +649,10 @@ impl IndexScheduler {
                     rtxn,
                     index_name.to_string(),
                     batchkind,
-                    batch_id,
+                    &mut current_batch,
                     create_index,
                 )?
-                .map(|batch| (batch, batch_id)));
+                .map(|batch| (batch, current_batch)));
         }
 
         // If we found no tasks then we were notified for something that got autobatched

crates/index-scheduler/src/insta_snapshot.rs

@@ -26,6 +26,7 @@ pub fn snapshot_index_scheduler(scheduler: &IndexScheduler) -> String {
         env,
         all_tasks,
         all_batches,
+        batch_to_tasks_mapping,
         // task reverse index
         status,
         kind,
@@ -67,7 +68,10 @@ pub fn snapshot_index_scheduler(scheduler: &IndexScheduler) -> String {
 
     let processing = processing_tasks.read().unwrap().clone();
     snap.push_str(&format!("### Autobatching Enabled = {autobatching_enabled}\n"));
-    snap.push_str(&format!("### Processing batch {:?}:\n", processing.batch_id));
+    snap.push_str(&format!(
+        "### Processing batch {:?}:\n",
+        processing.batch.map(|batch| batch.uid)
+    ));
     snap.push_str(&snapshot_bitmap(&processing.processing));
     snap.push_str("\n----------------------------------------------------------------------\n");
 
@@ -111,6 +115,10 @@ pub fn snapshot_index_scheduler(scheduler: &IndexScheduler) -> String {
     snap.push_str(&snapshot_all_batches(&rtxn, *all_batches));
     snap.push_str("----------------------------------------------------------------------\n");
 
+    snap.push_str("### Batch to tasks mapping:\n");
+    snap.push_str(&snapshot_batches_to_tasks_mappings(&rtxn, *batch_to_tasks_mapping));
+    snap.push_str("----------------------------------------------------------------------\n");
+
     snap.push_str("### Batches Status:\n");
     snap.push_str(&snapshot_status(&rtxn, *batch_status));
     snap.push_str("----------------------------------------------------------------------\n");
@@ -186,6 +194,19 @@ pub fn snapshot_all_batches(rtxn: &RoTxn, db: Database<BEU32, SerdeJson<Batch>>)
     snap
 }
 
+pub fn snapshot_batches_to_tasks_mappings(
+    rtxn: &RoTxn,
+    db: Database<BEU32, CboRoaringBitmapCodec>,
+) -> String {
+    let mut snap = String::new();
+    let iter = db.iter(rtxn).unwrap();
+    for next in iter {
+        let (batch_id, tasks) = next.unwrap();
+        snap.push_str(&format!("{batch_id} {}\n", snapshot_bitmap(&tasks)));
+    }
+    snap
+}
+
 pub fn snapshot_date_db(rtxn: &RoTxn, db: Database<BEI128, CboRoaringBitmapCodec>) -> String {
     let mut snap = String::new();
     let iter = db.iter(rtxn).unwrap();

crates/index-scheduler/src/snapshots/lib.rs/cancel_enqueued_task/initial_tasks_enqueued.snap

@@ -35,6 +35,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_mix_of_tasks/aborted_indexation.snap

@@ -47,6 +47,9 @@ catto: { number_of_documents: 1, field_distribution: {"id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/cancel_mix_of_tasks/first_task_processed.snap

@@ -43,6 +43,9 @@ catto: { number_of_documents: 1, field_distribution: {"id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/cancel_mix_of_tasks/processing_second_task_cancel_enqueued.snap

@@ -46,6 +46,9 @@ catto: { number_of_documents: 1, field_distribution: {"id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/cancel_processing_dump/after_dump_register.snap

@@ -31,6 +31,8 @@ enqueued [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_processing_dump/cancel_registered.snap

@@ -34,6 +34,8 @@ enqueued [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_processing_task/aborted_indexation.snap

@@ -36,6 +36,8 @@ catto: { number_of_documents: 0, field_distribution: {} }
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_processing_task/cancel_task_registered.snap

@@ -35,6 +35,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_processing_task/initial_task_processing.snap

@@ -32,6 +32,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_processing_task/registered_the_first_task.snap

@@ -32,6 +32,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/cancel_succeeded_task/cancel_processed.snap

@@ -44,6 +44,10 @@ catto: { number_of_documents: 1, field_distribution: {"id": 1} }
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/cancel_succeeded_task/initial_task_processed.snap

@@ -37,6 +37,9 @@ catto: { number_of_documents: 1, field_distribution: {"id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/cancel_succeeded_task/registered_the_first_task.snap

@@ -32,6 +32,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/do_not_batch_task_of_different_indexes/all_tasks_processed.snap

@@ -67,6 +67,14 @@ girafos: { number_of_documents: 0, field_distribution: {} }
 4 {uid: 4, }
 5 {uid: 5, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+4 [4,]
+5 [5,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,4,5,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_addition/after_register.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition/after_the_batch_creation.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition/once_everything_is_processed.snap

@@ -37,6 +37,9 @@ doggos: { number_of_documents: 1, field_distribution: {"doggo": 1, "id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_document_deletion/after_processing_the_batch.snap

@@ -40,6 +40,9 @@ doggos: { number_of_documents: 1, field_distribution: {"doggo": 1, "id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_document_deletion/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_document_deletion/registered_the_second_task.snap

@@ -35,6 +35,8 @@ doggos [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion/before_index_creation.snap

@@ -43,6 +43,9 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion/both_task_succeeded.snap

@@ -45,6 +45,10 @@ doggos [0,1,2,]
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion/registered_the_second_task.snap

@@ -35,6 +35,8 @@ doggos [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion/registered_the_third_task.snap

@@ -38,6 +38,8 @@ doggos [0,1,2,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion_on_unexisting_index/1.snap

@@ -35,6 +35,8 @@ doggos [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_addition_and_index_deletion_on_unexisting_index/2.snap

@@ -39,6 +39,9 @@ doggos [0,1,]
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_deletion_and_document_addition/after_failing_the_deletion.snap

@@ -39,6 +39,9 @@ doggos [0,1,]
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 failed [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/document_deletion_and_document_addition/after_last_successful_addition.snap

@@ -44,6 +44,10 @@ doggos: { number_of_documents: 3, field_distribution: {"catto": 1, "doggo": 2, "
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [1,]
 failed [0,]

crates/index-scheduler/src/snapshots/lib.rs/document_deletion_and_document_addition/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/document_deletion_and_document_addition/registered_the_second_task.snap

@@ -35,6 +35,8 @@ doggos [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_addition/document_addition_batch_created.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_addition/document_addition_failed.snap

@@ -36,6 +36,9 @@ doggos [0,]
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 failed [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_addition/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_deletion/after_adding_the_documents.snap

@@ -43,6 +43,10 @@ doggos: { number_of_documents: 3, field_distribution: {"catto": 1, "doggo": 2, "
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_deletion/after_adding_the_settings.snap

@@ -40,6 +40,9 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_deletion/after_removing_the_documents.snap

@@ -56,6 +56,11 @@ doggos: { number_of_documents: 1, field_distribution: {"doggo": 1, "id": 1} }
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,3,4,5,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,]
 failed [2,]

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_deletion/registered_the_document_deletions.snap

@@ -52,6 +52,10 @@ doggos: { number_of_documents: 3, field_distribution: {"catto": 1, "doggo": 2, "
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_document_deletion/registered_the_setting_and_document_addition.snap

@@ -35,6 +35,8 @@ doggos [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_index_creation/after_register.snap

@@ -32,6 +32,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_process_batch_for_index_creation/index_creation_failed.snap

@@ -36,6 +36,9 @@ catto [0,]
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 failed [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/fail_in_update_task_after_process_batch_success_for_document_addition/after_batch_succeeded.snap

@@ -33,6 +33,8 @@ doggos: { number_of_documents: 1, field_distribution: {"doggo": 1, "id": 1} }
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_update_task_after_process_batch_success_for_document_addition/after_failing_to_commit.snap

@@ -33,6 +33,8 @@ doggos: { number_of_documents: 1, field_distribution: {"doggo": 1, "id": 1} }
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_update_task_after_process_batch_success_for_document_addition/document_addition_succeeded_but_index_scheduler_not_updated.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_update_task_after_process_batch_success_for_document_addition/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/fail_in_update_task_after_process_batch_success_for_document_addition/task_successfully_processed.snap

@@ -37,6 +37,9 @@ doggos: { number_of_documents: 1, field_distribution: {"doggo": 1, "id": 1} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/import_vectors/Intel to kefir succeeds.snap

@@ -48,6 +48,11 @@ doggos: { number_of_documents: 1, field_distribution: {"_vectors": 1, "breed": 1
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/import_vectors/Intel to kefir.snap

@@ -45,6 +45,10 @@ doggos: { number_of_documents: 1, field_distribution: {"_vectors": 1, "breed": 1
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/import_vectors/adding Intel succeeds.snap

@@ -43,6 +43,10 @@ doggos: { number_of_documents: 1, field_distribution: {"_vectors": 1, "breed": 1
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/import_vectors/after adding Intel.snap

@@ -40,6 +40,9 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/import_vectors/after_registering_settings_task_vectors.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/import_vectors/settings_update_processed_vectors.snap

@@ -37,6 +37,9 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/insert_task_while_another_task_is_processing/after_batch_creation.snap

@@ -32,6 +32,8 @@ index_a [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/insert_task_while_another_task_is_processing/registered_the_first_task.snap

@@ -32,6 +32,8 @@ index_a [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/insert_task_while_another_task_is_processing/registered_the_second_task.snap

@@ -35,6 +35,8 @@ index_b [1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/insert_task_while_another_task_is_processing/registered_the_third_task.snap

@@ -38,6 +38,8 @@ index_b [1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/panic_in_process_batch_for_index_creation/index_creation_failed.snap

@@ -36,6 +36,9 @@ catto [0,]
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 failed [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/panic_in_process_batch_for_index_creation/registered_the_first_task.snap

@@ -32,6 +32,8 @@ catto [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_inserted_without_new_signal/processed_the_first_task.snap

@@ -43,6 +43,9 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_inserted_without_new_signal/processed_the_second_task.snap

@@ -47,6 +47,10 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_inserted_without_new_signal/processed_the_third_task.snap

@@ -49,6 +49,11 @@ cattos: { number_of_documents: 0, field_distribution: {} }
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_inserted_without_new_signal/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_inserted_without_new_signal/registered_the_second_task.snap

@@ -35,6 +35,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_inserted_without_new_signal/registered_the_third_task.snap

@@ -38,6 +38,8 @@ doggos [0,2,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/first.snap

@@ -44,6 +44,9 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/fourth.snap

@@ -53,6 +53,12 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 2 {uid: 2, }
 3 {uid: 3, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggos [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/registered_the_fourth_task.snap

@@ -39,6 +39,8 @@ doggos [0,1,2,3,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/registered_the_second_task.snap

@@ -35,6 +35,8 @@ doggos [0,1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/registered_the_third_task.snap

@@ -37,6 +37,8 @@ doggos [0,1,2,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/second.snap

@@ -47,6 +47,10 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/process_tasks_without_autobatching/third.snap

@@ -50,6 +50,11 @@ doggos: { number_of_documents: 0, field_distribution: {} }
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_from_and_limit/processed_all_tasks.snap

@@ -0,0 +1,90 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, batch_uid: 0, status: succeeded, details: { primary_key: Some("bone") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("bone") }}
+1 {uid: 1, batch_uid: 1, status: succeeded, details: { primary_key: Some("plankton") }, kind: IndexCreation { index_uid: "whalo", primary_key: Some("plankton") }}
+2 {uid: 2, batch_uid: 2, status: succeeded, details: { primary_key: Some("his_own_vomit") }, kind: IndexCreation { index_uid: "catto", primary_key: Some("his_own_vomit") }}
+----------------------------------------------------------------------
+### Status:
+enqueued []
+succeeded [0,1,2,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,2,]
+----------------------------------------------------------------------
+### Index Tasks:
+catto [2,]
+doggo [0,]
+whalo [1,]
+----------------------------------------------------------------------
+### Index Mapper:
+catto: { number_of_documents: 0, field_distribution: {} }
+doggo: { number_of_documents: 0, field_distribution: {} }
+whalo: { number_of_documents: 0, field_distribution: {} }
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Started At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Finished At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### All Batches:
+0 {uid: 0, }
+1 {uid: 1, }
+2 {uid: 2, }
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
+### Batches Status:
+succeeded [0,1,2,]
+----------------------------------------------------------------------
+### Batches Kind:
+"indexCreation" [0,1,2,]
+----------------------------------------------------------------------
+### Batches Index Tasks:
+catto [2,]
+doggo [0,]
+whalo [1,]
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Batches Started At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Batches Finished At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_from_and_limit/registered_the_first_task.snap

@@ -0,0 +1,54 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, status: enqueued, details: { primary_key: Some("bone") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("bone") }}
+----------------------------------------------------------------------
+### Status:
+enqueued [0,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,]
+----------------------------------------------------------------------
+### Index Tasks:
+doggo [0,]
+----------------------------------------------------------------------
+### Index Mapper:
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+----------------------------------------------------------------------
+### Started At:
+----------------------------------------------------------------------
+### Finished At:
+----------------------------------------------------------------------
+### All Batches:
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
+### Batches Status:
+----------------------------------------------------------------------
+### Batches Kind:
+----------------------------------------------------------------------
+### Batches Index Tasks:
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+----------------------------------------------------------------------
+### Batches Started At:
+----------------------------------------------------------------------
+### Batches Finished At:
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_from_and_limit/registered_the_second_task.snap

@@ -0,0 +1,57 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, status: enqueued, details: { primary_key: Some("bone") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("bone") }}
+1 {uid: 1, status: enqueued, details: { primary_key: Some("plankton") }, kind: IndexCreation { index_uid: "whalo", primary_key: Some("plankton") }}
+----------------------------------------------------------------------
+### Status:
+enqueued [0,1,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,]
+----------------------------------------------------------------------
+### Index Tasks:
+doggo [0,]
+whalo [1,]
+----------------------------------------------------------------------
+### Index Mapper:
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+----------------------------------------------------------------------
+### Started At:
+----------------------------------------------------------------------
+### Finished At:
+----------------------------------------------------------------------
+### All Batches:
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
+### Batches Status:
+----------------------------------------------------------------------
+### Batches Kind:
+----------------------------------------------------------------------
+### Batches Index Tasks:
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+----------------------------------------------------------------------
+### Batches Started At:
+----------------------------------------------------------------------
+### Batches Finished At:
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_from_and_limit/registered_the_third_task.snap

@@ -0,0 +1,60 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, status: enqueued, details: { primary_key: Some("bone") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("bone") }}
+1 {uid: 1, status: enqueued, details: { primary_key: Some("plankton") }, kind: IndexCreation { index_uid: "whalo", primary_key: Some("plankton") }}
+2 {uid: 2, status: enqueued, details: { primary_key: Some("his_own_vomit") }, kind: IndexCreation { index_uid: "catto", primary_key: Some("his_own_vomit") }}
+----------------------------------------------------------------------
+### Status:
+enqueued [0,1,2,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,2,]
+----------------------------------------------------------------------
+### Index Tasks:
+catto [2,]
+doggo [0,]
+whalo [1,]
+----------------------------------------------------------------------
+### Index Mapper:
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Started At:
+----------------------------------------------------------------------
+### Finished At:
+----------------------------------------------------------------------
+### All Batches:
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
+### Batches Status:
+----------------------------------------------------------------------
+### Batches Kind:
+----------------------------------------------------------------------
+### Batches Index Tasks:
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+----------------------------------------------------------------------
+### Batches Started At:
+----------------------------------------------------------------------
+### Batches Finished At:
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_simple/end.snap

@@ -0,0 +1,91 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, batch_uid: 0, status: succeeded, details: { primary_key: Some("mouse") }, kind: IndexCreation { index_uid: "catto", primary_key: Some("mouse") }}
+1 {uid: 1, batch_uid: 1, status: succeeded, details: { primary_key: Some("sheep") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("sheep") }}
+2 {uid: 2, batch_uid: 2, status: failed, error: ResponseError { code: 200, message: "Planned failure for tests.", error_code: "internal", error_type: "internal", error_link: "https://docs.meilisearch.com/errors#internal" }, details: { primary_key: Some("fish") }, kind: IndexCreation { index_uid: "whalo", primary_key: Some("fish") }}
+----------------------------------------------------------------------
+### Status:
+enqueued []
+succeeded [0,1,]
+failed [2,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,2,]
+----------------------------------------------------------------------
+### Index Tasks:
+catto [0,]
+doggo [1,]
+whalo [2,]
+----------------------------------------------------------------------
+### Index Mapper:
+catto: { number_of_documents: 0, field_distribution: {} }
+doggo: { number_of_documents: 0, field_distribution: {} }
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Started At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Finished At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### All Batches:
+0 {uid: 0, }
+1 {uid: 1, }
+2 {uid: 2, }
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
+### Batches Status:
+succeeded [0,1,]
+failed [2,]
+----------------------------------------------------------------------
+### Batches Kind:
+"indexCreation" [0,1,2,]
+----------------------------------------------------------------------
+### Batches Index Tasks:
+catto [0,]
+doggo [1,]
+whalo [2,]
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Batches Started At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Batches Finished At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_simple/start.snap

@@ -0,0 +1,60 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, status: enqueued, details: { primary_key: Some("mouse") }, kind: IndexCreation { index_uid: "catto", primary_key: Some("mouse") }}
+1 {uid: 1, status: enqueued, details: { primary_key: Some("sheep") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("sheep") }}
+2 {uid: 2, status: enqueued, details: { primary_key: Some("fish") }, kind: IndexCreation { index_uid: "whalo", primary_key: Some("fish") }}
+----------------------------------------------------------------------
+### Status:
+enqueued [0,1,2,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,2,]
+----------------------------------------------------------------------
+### Index Tasks:
+catto [0,]
+doggo [1,]
+whalo [2,]
+----------------------------------------------------------------------
+### Index Mapper:
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+----------------------------------------------------------------------
+### Started At:
+----------------------------------------------------------------------
+### Finished At:
+----------------------------------------------------------------------
+### All Batches:
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
+### Batches Status:
+----------------------------------------------------------------------
+### Batches Kind:
+----------------------------------------------------------------------
+### Batches Index Tasks:
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+----------------------------------------------------------------------
+### Batches Started At:
+----------------------------------------------------------------------
+### Batches Finished At:
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_special_rules/after-processing-everything.snap

@@ -0,0 +1,102 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, batch_uid: 0, status: succeeded, details: { primary_key: Some("mouse") }, kind: IndexCreation { index_uid: "catto", primary_key: Some("mouse") }}
+1 {uid: 1, batch_uid: 1, status: succeeded, details: { primary_key: Some("sheep") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("sheep") }}
+2 {uid: 2, batch_uid: 2, status: failed, error: ResponseError { code: 200, message: "Planned failure for tests.", error_code: "internal", error_type: "internal", error_link: "https://docs.meilisearch.com/errors#internal" }, details: { swaps: [IndexSwap { indexes: ("catto", "doggo") }] }, kind: IndexSwap { swaps: [IndexSwap { indexes: ("catto", "doggo") }] }}
+3 {uid: 3, batch_uid: 3, status: failed, error: ResponseError { code: 200, message: "Index `whalo` not found.", error_code: "index_not_found", error_type: "invalid_request", error_link: "https://docs.meilisearch.com/errors#index_not_found" }, details: { swaps: [IndexSwap { indexes: ("catto", "whalo") }] }, kind: IndexSwap { swaps: [IndexSwap { indexes: ("catto", "whalo") }] }}
+----------------------------------------------------------------------
+### Status:
+enqueued []
+succeeded [0,1,]
+failed [2,3,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,]
+"indexSwap" [2,3,]
+----------------------------------------------------------------------
+### Index Tasks:
+catto [0,2,3,]
+doggo [1,2,]
+whalo [3,]
+----------------------------------------------------------------------
+### Index Mapper:
+catto: { number_of_documents: 0, field_distribution: {} }
+doggo: { number_of_documents: 0, field_distribution: {} }
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### Started At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### Finished At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### All Batches:
+0 {uid: 0, }
+1 {uid: 1, }
+2 {uid: 2, }
+3 {uid: 3, }
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+----------------------------------------------------------------------
+### Batches Status:
+succeeded [0,1,]
+failed [2,3,]
+----------------------------------------------------------------------
+### Batches Kind:
+"indexCreation" [0,1,]
+"indexSwap" [2,3,]
+----------------------------------------------------------------------
+### Batches Index Tasks:
+catto [0,2,3,]
+doggo [1,2,]
+whalo [3,]
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### Batches Started At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### Batches Finished At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_batches_special_rules/start.snap

@@ -0,0 +1,63 @@
+---
+source: crates/index-scheduler/src/lib.rs
+---
+### Autobatching Enabled = true
+### Processing batch None:
+[]
+----------------------------------------------------------------------
+### All Tasks:
+0 {uid: 0, status: enqueued, details: { primary_key: Some("mouse") }, kind: IndexCreation { index_uid: "catto", primary_key: Some("mouse") }}
+1 {uid: 1, status: enqueued, details: { primary_key: Some("sheep") }, kind: IndexCreation { index_uid: "doggo", primary_key: Some("sheep") }}
+2 {uid: 2, status: enqueued, details: { swaps: [IndexSwap { indexes: ("catto", "doggo") }] }, kind: IndexSwap { swaps: [IndexSwap { indexes: ("catto", "doggo") }] }}
+3 {uid: 3, status: enqueued, details: { swaps: [IndexSwap { indexes: ("catto", "whalo") }] }, kind: IndexSwap { swaps: [IndexSwap { indexes: ("catto", "whalo") }] }}
+----------------------------------------------------------------------
+### Status:
+enqueued [0,1,2,3,]
+----------------------------------------------------------------------
+### Kind:
+"indexCreation" [0,1,]
+"indexSwap" [2,3,]
+----------------------------------------------------------------------
+### Index Tasks:
+catto [0,2,3,]
+doggo [1,2,]
+whalo [3,]
+----------------------------------------------------------------------
+### Index Mapper:
+
+----------------------------------------------------------------------
+### Canceled By:
+
+----------------------------------------------------------------------
+### Enqueued At:
+[timestamp] [0,]
+[timestamp] [1,]
+[timestamp] [2,]
+[timestamp] [3,]
+----------------------------------------------------------------------
+### Started At:
+----------------------------------------------------------------------
+### Finished At:
+----------------------------------------------------------------------
+### All Batches:
+----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
+### Batches Status:
+----------------------------------------------------------------------
+### Batches Kind:
+----------------------------------------------------------------------
+### Batches Index Tasks:
+----------------------------------------------------------------------
+### Batches Canceled By:
+
+----------------------------------------------------------------------
+### Batches Enqueued At:
+----------------------------------------------------------------------
+### Batches Started At:
+----------------------------------------------------------------------
+### Batches Finished At:
+----------------------------------------------------------------------
+### File Store:
+
+----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_from_and_limit/processed_all_tasks.snap

@@ -51,6 +51,11 @@ whalo: { number_of_documents: 0, field_distribution: {} }
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_from_and_limit/registered_the_first_task.snap

@@ -32,6 +32,8 @@ doggo [0,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_from_and_limit/registered_the_second_task.snap

@@ -35,6 +35,8 @@ whalo [1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_from_and_limit/registered_the_third_task.snap

@@ -38,6 +38,8 @@ whalo [1,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_simple/end.snap

@@ -51,6 +51,11 @@ doggo: { number_of_documents: 0, field_distribution: {} }
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 failed [2,]

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_simple/start.snap

@@ -38,6 +38,8 @@ whalo [2,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/query_tasks_special_rules/start.snap

@@ -41,6 +41,8 @@ whalo [3,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/register/everything_is_successfully_registered.snap

@@ -40,6 +40,8 @@ doggo [3,]
 ----------------------------------------------------------------------
 ### All Batches:
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+----------------------------------------------------------------------
 ### Batches Status:
 ----------------------------------------------------------------------
 ### Batches Kind:

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/create_a.snap

@@ -46,6 +46,9 @@ a: { number_of_documents: 0, field_distribution: {} }
 ### All Batches:
 0 {uid: 0, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/create_b.snap

@@ -50,6 +50,10 @@ b: { number_of_documents: 0, field_distribution: {} }
 0 {uid: 0, }
 1 {uid: 1, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/create_c.snap

@@ -54,6 +54,11 @@ c: { number_of_documents: 0, field_distribution: {} }
 1 {uid: 1, }
 2 {uid: 2, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/create_d.snap

@@ -58,6 +58,12 @@ d: { number_of_documents: 0, field_distribution: {} }
 2 {uid: 2, }
 3 {uid: 3, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/first_swap_processed.snap

@@ -66,6 +66,13 @@ d: { number_of_documents: 0, field_distribution: {} }
 3 {uid: 3, }
 4 {uid: 4, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+4 [4,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,4,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/first_swap_registered.snap

@@ -61,6 +61,12 @@ d: { number_of_documents: 0, field_distribution: {} }
 2 {uid: 2, }
 3 {uid: 3, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/second_swap_processed.snap

@@ -69,6 +69,14 @@ d: { number_of_documents: 0, field_distribution: {} }
 4 {uid: 4, }
 5 {uid: 5, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+4 [4,]
+5 [5,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,4,5,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/third_empty_swap_processed.snap

@@ -74,6 +74,15 @@ d: { number_of_documents: 0, field_distribution: {} }
 5 {uid: 5, }
 6 {uid: 6, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+4 [4,]
+5 [5,]
+6 [6,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,4,5,6,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes/two_swaps_registered.snap

@@ -63,6 +63,12 @@ d: { number_of_documents: 0, field_distribution: {} }
 2 {uid: 2, }
 3 {uid: 3, }
 ----------------------------------------------------------------------
+### Batch to tasks mapping:
+0 [0,]
+1 [1,]
+2 [2,]
+3 [3,]
+----------------------------------------------------------------------
 ### Batches Status:
 succeeded [0,1,2,3,]
 ----------------------------------------------------------------------