Merge e2e5e0e22e into cf07189bd2

7 months ago · a09dc435c2
parent cf07189bd2 e2e5e0e22e
commit a09dc435c2
1 changed files with 6 additions and 4 deletions
--- a/api/services/dataset_service.py
+++ b/api/services/dataset_service.py
@ -1353,10 +1353,12 @@ class DocumentService:
                db.session.commit()

                # trigger async task
-                if document_ids:
-                    document_indexing_task.delay(dataset.id, document_ids)
-                if duplicate_document_ids:
-                    duplicate_document_indexing_task.delay(dataset.id, duplicate_document_ids)
+            if document_ids:
+                for dociment_id in document_ids:
+                    document_indexing_task.delay(dataset.id, [dociment_id])
+            if duplicate_document_ids:
+                for duplicate_document_id in duplicate_document_ids:
+                    duplicate_document_indexing_task.delay(dataset.id, [duplicate_document_id])

        return documents, batch