add the mapping between the task and batches

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,
@@ -111,6 +112,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 +191,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/lib.rs

@@ -85,6 +85,10 @@ pub struct Query {
     pub limit: Option<u32>,
     /// The minimum [task id](`meilisearch_types::tasks::Task::uid`) to be matched
     pub from: Option<u32>,
+    /// The [task ids](`meilisearch_types::tasks::Task::uid`) to be matched
+    pub uids: Option<Vec<TaskId>>,
+    /// The [batch ids](`meilisearch_types::batches::Batch::uid`) to be matched
+    pub batch_uids: Option<Vec<BatchId>>,
     /// The allowed [statuses](`meilisearch_types::tasks::Task::status`) of the matched tasls
     pub statuses: Option<Vec<Status>>,
     /// The allowed [kinds](meilisearch_types::tasks::Kind) of the matched tasks.
@@ -99,8 +103,6 @@ pub struct Query {
     pub types: Option<Vec<Kind>>,
     /// The allowed [index ids](meilisearch_types::tasks::Task::index_uid) of the matched tasks
     pub index_uids: Option<Vec<String>>,
-    /// The [task ids](`meilisearch_types::tasks::Task::uid`) to be matched
-    pub uids: Option<Vec<TaskId>>,
     /// The [task ids](`meilisearch_types::tasks::Task::uid`) of the [`TaskCancelation`](meilisearch_types::tasks::Task::Kind::TaskCancelation) tasks
     /// that canceled the matched tasks.
     pub canceled_by: Option<Vec<TaskId>>,
@@ -127,10 +129,11 @@ impl Query {
             Query {
                 limit: None,
                 from: None,
+                uids: None,
+                batch_uids: None,
                 statuses: None,
                 types: None,
                 index_uids: None,
-                uids: None,
                 canceled_by: None,
                 before_enqueued_at: None,
                 after_enqueued_at: None,
@@ -224,6 +227,7 @@ impl MustStopProcessing {
 mod db_name {
     pub const ALL_TASKS: &str = "all-tasks";
     pub const ALL_BATCHES: &str = "all-batches";
+    pub const BATCH_TO_TASKS_MAPPING: &str = "batch-to-tasks-mapping";
     pub const STATUS: &str = "status";
     pub const KIND: &str = "kind";
     pub const INDEX_TASKS: &str = "index-tasks";
@@ -320,30 +324,14 @@ pub struct IndexScheduler {
     /// The list of files referenced by the tasks
     pub(crate) file_store: FileStore,
 
-    // The main database, it contains all the tasks accessible by their Id.
+    /// The main database, it contains all the tasks accessible by their Id.
     pub(crate) all_tasks: Database<BEU32, SerdeJson<Task>>,
 
-    // Contains all the batches accessible by their Id.
+    /// Contains all the batches accessible by their Id.
     pub(crate) all_batches: Database<BEU32, SerdeJson<Batch>>,
 
-    /// All the batches containing a task matching the selected status.
+    /// Matches a batch id with the associated task ids.
-    pub(crate) batch_status: Database<SerdeBincode<Status>, RoaringBitmapCodec>,
+    pub(crate) batch_to_tasks_mapping: Database<BEU32, CboRoaringBitmapCodec>,
-    /// All the batches ids grouped by the kind of their task.
-    pub(crate) batch_kind: Database<SerdeBincode<Kind>, RoaringBitmapCodec>,
-    /// Store the batches associated to an index.
-    pub(crate) batch_index_tasks: Database<Str, RoaringBitmapCodec>,
-
-    /// Store the batches containing a task canceled by a task uid
-    pub(crate) batch_canceled_by: Database<BEU32, RoaringBitmapCodec>,
-
-    /// Store the batches containing tasks which were enqueued at a specific date
-    pub(crate) batch_enqueued_at: Database<BEI128, CboRoaringBitmapCodec>,
-
-    /// Store the batches containing finished tasks started at a specific date
-    pub(crate) batch_started_at: Database<BEI128, CboRoaringBitmapCodec>,
-
-    /// Store the batches containing tasks finished at a specific date
-    pub(crate) batch_finished_at: Database<BEI128, CboRoaringBitmapCodec>,
 
     /// All the tasks ids grouped by their status.
     // TODO we should not be able to serialize a `Status::Processing` in this database.
@@ -352,19 +340,30 @@ pub struct IndexScheduler {
     pub(crate) kind: Database<SerdeBincode<Kind>, RoaringBitmapCodec>,
     /// Store the tasks associated to an index.
     pub(crate) index_tasks: Database<Str, RoaringBitmapCodec>,
-
     /// Store the tasks that were canceled by a task uid
     pub(crate) canceled_by: Database<BEU32, RoaringBitmapCodec>,
-
     /// Store the task ids of tasks which were enqueued at a specific date
     pub(crate) enqueued_at: Database<BEI128, CboRoaringBitmapCodec>,
-
     /// Store the task ids of finished tasks which started being processed at a specific date
     pub(crate) started_at: Database<BEI128, CboRoaringBitmapCodec>,
-
     /// Store the task ids of tasks which finished at a specific date
     pub(crate) finished_at: Database<BEI128, CboRoaringBitmapCodec>,
 
+    /// All the batches containing a task matching the selected status.
+    pub(crate) batch_status: Database<SerdeBincode<Status>, RoaringBitmapCodec>,
+    /// All the batches ids grouped by the kind of their task.
+    pub(crate) batch_kind: Database<SerdeBincode<Kind>, RoaringBitmapCodec>,
+    /// Store the batches associated to an index.
+    pub(crate) batch_index_tasks: Database<Str, RoaringBitmapCodec>,
+    /// Store the batches containing a task canceled by a task uid
+    pub(crate) batch_canceled_by: Database<BEU32, RoaringBitmapCodec>,
+    /// Store the batches containing tasks which were enqueued at a specific date
+    pub(crate) batch_enqueued_at: Database<BEI128, CboRoaringBitmapCodec>,
+    /// Store the batches containing finished tasks started at a specific date
+    pub(crate) batch_started_at: Database<BEI128, CboRoaringBitmapCodec>,
+    /// Store the batches containing tasks finished at a specific date
+    pub(crate) batch_finished_at: Database<BEI128, CboRoaringBitmapCodec>,
+
     /// In charge of creating, opening, storing and returning indexes.
     pub(crate) index_mapper: IndexMapper,
 
@@ -434,6 +433,7 @@ impl IndexScheduler {
             file_store: self.file_store.clone(),
             all_tasks: self.all_tasks,
             all_batches: self.all_batches,
+            batch_to_tasks_mapping: self.batch_to_tasks_mapping,
 
             // Tasks reverse index
             status: self.status,
@@ -512,7 +512,7 @@ impl IndexScheduler {
 
         let env = unsafe {
             heed::EnvOpenOptions::new()
-                .max_dbs(19)
+                .max_dbs(20)
                 .map_size(budget.task_db_size)
                 .open(options.tasks_path)
         }?;
@@ -524,6 +524,9 @@ impl IndexScheduler {
         let mut wtxn = env.write_txn()?;
         let all_tasks = env.create_database(&mut wtxn, Some(db_name::ALL_TASKS))?;
         let all_batches = env.create_database(&mut wtxn, Some(db_name::ALL_BATCHES))?;
+        let batch_to_tasks_mapping =
+            env.create_database(&mut wtxn, Some(db_name::BATCH_TO_TASKS_MAPPING))?;
+
         let status = env.create_database(&mut wtxn, Some(db_name::STATUS))?;
         let kind = env.create_database(&mut wtxn, Some(db_name::KIND))?;
         let index_tasks = env.create_database(&mut wtxn, Some(db_name::INDEX_TASKS))?;
@@ -548,6 +551,7 @@ impl IndexScheduler {
             file_store,
             all_tasks,
             all_batches,
+            batch_to_tasks_mapping,
             // Task reverse indexes
             status,
             kind,
@@ -782,16 +786,46 @@ impl IndexScheduler {
     /// Return the task ids matched by the given query from the index scheduler's point of view.
     pub(crate) fn get_task_ids(&self, rtxn: &RoTxn, query: &Query) -> Result<RoaringBitmap> {
         let ProcessingTasks {
-            started_at: started_at_processing, processing: processing_tasks, ..
+            started_at: started_at_processing,
+            processing: processing_tasks,
+            batch_id: current_batch_processing,
         } = self.processing_tasks.read().unwrap().clone();
+        let Query {
+            limit,
+            from,
+            uids,
+            batch_uids,
+            statuses,
+            types,
+            index_uids,
+            canceled_by,
+            before_enqueued_at,
+            after_enqueued_at,
+            before_started_at,
+            after_started_at,
+            before_finished_at,
+            after_finished_at,
+        } = query;
 
         let mut tasks = self.all_task_ids(rtxn)?;
 
-        if let Some(from) = &query.from {
+        if let Some(from) = from {
             tasks.remove_range(from.saturating_add(1)..);
         }
 
-        if let Some(status) = &query.statuses {
+        if let Some(batch_uids) = batch_uids {
+            let mut batch_tasks = RoaringBitmap::new();
+            for batch_uid in batch_uids {
+                if Some(*batch_uid) == current_batch_processing {
+                    batch_tasks |= &processing_tasks;
+                } else {
+                    batch_tasks |= self.tasks_in_batch(rtxn, *batch_uid)?;
+                }
+            }
+            tasks &= batch_tasks;
+        }
+
+        if let Some(status) = statuses {
             let mut status_tasks = RoaringBitmap::new();
             for status in status {
                 match status {
@@ -808,12 +842,12 @@ impl IndexScheduler {
             tasks &= status_tasks;
         }
 
-        if let Some(uids) = &query.uids {
+        if let Some(uids) = uids {
             let uids = RoaringBitmap::from_iter(uids);
             tasks &= &uids;
         }
 
-        if let Some(canceled_by) = &query.canceled_by {
+        if let Some(canceled_by) = canceled_by {
             let mut all_canceled_tasks = RoaringBitmap::new();
             for cancel_task_uid in canceled_by {
                 if let Some(canceled_by_uid) = self.canceled_by.get(rtxn, cancel_task_uid)? {
@@ -830,7 +864,7 @@ impl IndexScheduler {
             }
         }
 
-        if let Some(kind) = &query.types {
+        if let Some(kind) = types {
             let mut kind_tasks = RoaringBitmap::new();
             for kind in kind {
                 kind_tasks |= self.get_kind(rtxn, *kind)?;
@@ -838,7 +872,7 @@ impl IndexScheduler {
             tasks &= &kind_tasks;
         }
 
-        if let Some(index) = &query.index_uids {
+        if let Some(index) = index_uids {
             let mut index_tasks = RoaringBitmap::new();
             for index in index {
                 index_tasks |= self.index_tasks(rtxn, index)?;
@@ -868,25 +902,26 @@ impl IndexScheduler {
                         filtered_processing_tasks.clear();
                     }
                 };
-            match (query.after_started_at, query.before_started_at) {
+            match (after_started_at, before_started_at) {
                 (None, None) => (),
                 (None, Some(before)) => {
-                    clear_filtered_processing_tasks(Bound::Unbounded, Bound::Excluded(before))
+                    clear_filtered_processing_tasks(Bound::Unbounded, Bound::Excluded(*before))
                 }
                 (Some(after), None) => {
-                    clear_filtered_processing_tasks(Bound::Excluded(after), Bound::Unbounded)
+                    clear_filtered_processing_tasks(Bound::Excluded(*after), Bound::Unbounded)
-                }
-                (Some(after), Some(before)) => {
-                    clear_filtered_processing_tasks(Bound::Excluded(after), Bound::Excluded(before))
                 }
+                (Some(after), Some(before)) => clear_filtered_processing_tasks(
+                    Bound::Excluded(*after),
+                    Bound::Excluded(*before),
+                ),
             };
 
             keep_tasks_within_datetimes(
                 rtxn,
                 &mut filtered_non_processing_tasks,
                 self.started_at,
-                query.after_started_at,
+                *after_started_at,
-                query.before_started_at,
+                *before_started_at,
             )?;
             filtered_non_processing_tasks | filtered_processing_tasks
         };
@@ -895,19 +930,19 @@ impl IndexScheduler {
             rtxn,
             &mut tasks,
             self.enqueued_at,
-            query.after_enqueued_at,
+            *after_enqueued_at,
-            query.before_enqueued_at,
+            *before_enqueued_at,
         )?;
 
         keep_tasks_within_datetimes(
             rtxn,
             &mut tasks,
             self.finished_at,
-            query.after_finished_at,
+            *after_finished_at,
-            query.before_finished_at,
+            *before_finished_at,
         )?;
 
-        if let Some(limit) = query.limit {
+        if let Some(limit) = *limit {
             tasks = tasks.into_iter().rev().take(limit as usize).collect();
         }
 
@@ -1597,7 +1632,7 @@ impl IndexScheduler {
 
         let processed = self.processing_tasks.write().unwrap().stop_processing();
 
-        self.write_batch(&mut wtxn, current_batch)?;
+        self.write_batch(&mut wtxn, current_batch, &processed.processing)?;
 
         #[cfg(test)]
         self.maybe_fail(tests::FailureLocation::CommittingWtxn)?;
@@ -5405,6 +5440,8 @@ mod tests {
         ----------------------------------------------------------------------
         ### All Batches:
         ----------------------------------------------------------------------
+        ### Batch to tasks mapping:
+        ----------------------------------------------------------------------
         ### Batches Status:
         ----------------------------------------------------------------------
         ### Batches Kind:
@@ -5455,6 +5492,8 @@ mod tests {
         ----------------------------------------------------------------------
         ### All Batches:
         ----------------------------------------------------------------------
+        ### Batch to tasks mapping:
+        ----------------------------------------------------------------------
         ### Batches Status:
         ----------------------------------------------------------------------
         ### Batches Kind:

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_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,]
 ----------------------------------------------------------------------

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes_errors/after_the_index_creation.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_errors/first_swap_failed.snap

@@ -67,6 +67,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,]
 failed [4,]

crates/index-scheduler/src/snapshots/lib.rs/swap_indexes_errors/initial_tasks_processed.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/task_deletion_delete_same_task_twice/initial_tasks_enqueued.snap

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

crates/index-scheduler/src/snapshots/lib.rs/task_deletion_delete_same_task_twice/initial_tasks_processed.snap

@@ -40,6 +40,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/task_deletion_delete_same_task_twice/task_deletion_processed.snap

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

crates/index-scheduler/src/snapshots/lib.rs/task_deletion_deleteable/after_registering_the_task_deletion.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/task_deletion_deleteable/initial_tasks_enqueued.snap

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

crates/index-scheduler/src/snapshots/lib.rs/task_deletion_deleteable/initial_tasks_processed.snap

@@ -40,6 +40,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,]
 ----------------------------------------------------------------------