diff --git a/llama-index-integrations/vector_stores/llama-index-vector-stores-opensearch/llama_index/vector_stores/opensearch/base.py b/llama-index-integrations/vector_stores/llama-index-vector-stores-opensearch/llama_index/vector_stores/opensearch/base.py index c30b5f792c15b9c3ebf45f6f51ca9786f92afea5..b06b8b3c73228905f779c7fff70a80afb2f7ce5b 100644 --- a/llama-index-integrations/vector_stores/llama-index-vector-stores-opensearch/llama_index/vector_stores/opensearch/base.py +++ b/llama-index-integrations/vector_stores/llama-index-vector-stores-opensearch/llama_index/vector_stores/opensearch/base.py @@ -365,7 +365,10 @@ class OpensearchVectorClient: Args: doc_id (str): document id """ - await self._os_client.delete(index=self._index, id=doc_id) + search_query = { + "query": {"term": {"metadata.doc_id.keyword": {"value": doc_id}}} + } + await self._os_client.delete_by_query(index=self._index, body=search_query) async def aquery( self,