fix(elasticsearch): override duplicate fail mixin test to match ES error type

Author: SyedShahmeerAli12

integrations/elasticsearch/tests/test_document_store_async.py

@@ -79,6 +79,14 @@ async def test_delete_documents_non_existing_document_async(self, document_store
         with pytest.raises(DocumentStoreError):
             await document_store.delete_documents_async(["non_existing_id"])
 
+    @pytest.mark.asyncio
+    async def test_write_documents_duplicate_fail_async(self, document_store):
+        # Elasticsearch raises DocumentStoreError instead of DuplicateDocumentError on duplicate FAIL
+        doc = Document(content="test doc")
+        assert await document_store.write_documents_async([doc], policy=DuplicatePolicy.FAIL) == 1
+        with pytest.raises(DocumentStoreError):
+            await document_store.write_documents_async(documents=[doc], policy=DuplicatePolicy.FAIL)
+
     @pytest.mark.asyncio
     async def test_write_documents_async(self, document_store):
         docs = [Document(id="1", content="test")]