diff --git a/libs/community/langchain_community/vectorstores/milvus.py b/libs/community/langchain_community/vectorstores/milvus.py index 476f165121..692f2084d5 100644 --- a/libs/community/langchain_community/vectorstores/milvus.py +++ b/libs/community/langchain_community/vectorstores/milvus.py @@ -528,6 +528,7 @@ class Milvus(VectorStore): "Failed to insert batch starting at entity: %s/%s", i, total_count ) raise e + self.col.flush() return pks def similarity_search(