Support aborting documents edition by function

2025-07-23 23:00:59 +00:00 · 2024-05-11 11:39:58 +02:00
parent 33fa17bf12
commit 2eae2015d7
1 changed files with 4 additions and 0 deletions
--- 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) => {