From d4d7c9d577cbf23c3821df40efaeecc9c6799d2e Mon Sep 17 00:00:00 2001
From: Kerollmops <clement@meilisearch.com>
Date: Tue, 13 Sep 2022 14:03:00 +0200
Subject: [PATCH] We avoid skipping errors in the indexing pipeline

---
 milli/src/update/index_documents/mod.rs | 35 ++++++++++++-------------
 1 file changed, 17 insertions(+), 18 deletions(-)

diff --git a/milli/src/update/index_documents/mod.rs b/milli/src/update/index_documents/mod.rs
index 365b0d024..be45499c6 100644
--- a/milli/src/update/index_documents/mod.rs
+++ b/milli/src/update/index_documents/mod.rs
@@ -304,24 +304,23 @@ where
                 documents_chunk_size,
             );
 
-            let result = original_chunk_iter
-                .and_then(|original_chunk_iter| Ok((original_chunk_iter, flattened_chunk_iter?)))
-                .map(|(original_chunk, flattened_chunk)| {
-                    // extract all databases from the chunked obkv douments
-                    extract::data_from_obkv_documents(
-                        original_chunk,
-                        flattened_chunk,
-                        pool_params,
-                        lmdb_writer_sx.clone(),
-                        searchable_fields,
-                        faceted_fields,
-                        primary_key_id,
-                        geo_fields_ids,
-                        stop_words,
-                        max_positions_per_attributes,
-                        exact_attributes,
-                    )
-                });
+            let result = original_chunk_iter.and_then(|original_chunk| {
+                let flattened_chunk = flattened_chunk_iter?;
+                // extract all databases from the chunked obkv douments
+                extract::data_from_obkv_documents(
+                    original_chunk,
+                    flattened_chunk,
+                    pool_params,
+                    lmdb_writer_sx.clone(),
+                    searchable_fields,
+                    faceted_fields,
+                    primary_key_id,
+                    geo_fields_ids,
+                    stop_words,
+                    max_positions_per_attributes,
+                    exact_attributes,
+                )
+            });
 
             if let Err(e) = result {
                 let _ = lmdb_writer_sx.send(Err(e));