diff --git a/milli/src/update/index_documents/mod.rs b/milli/src/update/index_documents/mod.rs index 0ec4b3739..d3cf2fd12 100644 --- a/milli/src/update/index_documents/mod.rs +++ b/milli/src/update/index_documents/mod.rs @@ -236,6 +236,10 @@ where }; for docid in documents { + if (self.should_abort)() { + return Err(Error::InternalError(InternalError::AbortedIndexation)); + } + let (document, document_object, document_id) = match self.index.documents.get(self.wtxn, &docid)? { Some(obkv) => {