Fixing ElasticsearchVectorStoreIT test failures

sobychacko · sobychacko · commit 1fee0827e46f · 2025-02-06T14:10:02.000-05:00
Signed-off-by: Soby Chacko &lt;soby.chacko@broadcom.com&gt;
diff --git a/vector-stores/spring-ai-elasticsearch-store/src/main/java/org/springframework/ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java b/vector-stores/spring-ai-elasticsearch-store/src/main/java/org/springframework/ai/vectorstore/elasticsearch/ElasticsearchVectorStore.java
@@ -219,6 +219,9 @@ public void doDelete(List<String> idList) {
 		for (String id : idList) {
 			bulkRequestBuilder.operations(op -> op.delete(idx -> idx.index(this.options.getIndexName()).id(id)));
 		}
+		if (bulkRequest(bulkRequestBuilder.build()).errors()) {
+			throw new IllegalStateException("Delete operation failed");
+		}
 	}
 
 	@Override

Original file line number	Diff line number	Diff line change
`@@ -219,6 +219,9 @@ public void doDelete(List<String> idList) {`
`219`	`219`	`for (String id : idList) {`
`220`	`220`	`bulkRequestBuilder.operations(op -> op.delete(idx -> idx.index(this.options.getIndexName()).id(id)));`
`221`	`221`	`}`
	`222`	`+ if (bulkRequest(bulkRequestBuilder.build()).errors()) {`
	`223`	`+ throw new IllegalStateException("Delete operation failed");`
	`224`	`+ }`
`222`	`225`	`}`
`223`	`226`
`224`	`227`	`@Override`