Fix async indexing issue

`aindex` function should check not only `adelete` method, but `delete` method too
This commit is contained in:
Shkarupa Alex 2025-04-16 10:44:19 +03:00 committed by GitHub
parent 4ff576e37d
commit 24eb244ffb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -647,10 +647,10 @@ async def aindex(
)
raise ValueError(msg)
if type(destination).adelete == VectorStore.adelete:
# Checking if the vectorstore has overridden the default delete method
if type(destination).adelete == VectorStore.adelete and type(destination).delete == VectorStore.delete:
# Checking if the vectorstore has overridden the default adelete or delete methods
# implementation which just raises a NotImplementedError
msg = "Vectorstore has not implemented the delete method"
msg = "Vectorstore has not implemented the adelete or delete method"
raise ValueError(msg)
elif isinstance(destination, DocumentIndex):
pass