fix(elasticsearch): use create op for SKIP policy to enable proper skip counting

SyedShahmeerAli12 · SyedShahmeerAli12 · commit 84dc4687439a · 2026-04-22T13:27:40.000+05:00
diff --git a/integrations/elasticsearch/src/haystack_integrations/document_stores/elasticsearch/document_store.py b/integrations/elasticsearch/src/haystack_integrations/document_stores/elasticsearch/document_store.py
@@ -704,7 +704,7 @@ async def write_documents_async(
             self._handle_sparse_embedding(doc_dict, doc.id)
 
             action = {
-                "_op_type": "create" if policy == DuplicatePolicy.FAIL else "index",
+                "_op_type": "index" if policy == DuplicatePolicy.OVERWRITE else "create",
                 "_id": doc.id,
                 "_source": doc_dict,
             }

Original file line number	Diff line number	Diff line change
`@@ -704,7 +704,7 @@ async def write_documents_async(`
`704`	`704`	`self._handle_sparse_embedding(doc_dict, doc.id)`
`705`	`705`
`706`	`706`	`action = {`
`707`		`- "_op_type": "create" if policy == DuplicatePolicy.FAIL else "index",`
	`707`	`+ "_op_type": "index" if policy == DuplicatePolicy.OVERWRITE else "create",`
`708`	`708`	`"_id": doc.id,`
`709`	`709`	`"_source": doc_dict,`
`710`	`710`	`}`