fix: 移除 collection.flush() Fixes #297

Author: xerrors

src/knowledge/implementations/milvus.py

@@ -263,11 +263,10 @@ async def add_content(self, db_id: str, items: list[str], params: dict | None =
                         embeddings,
                     ]
 
-                    def _insert_and_flush():
+                    def _insert_records():
                         collection.insert(entities)
-                        collection.flush()
 
-                    await asyncio.to_thread(_insert_and_flush)
+                    await asyncio.to_thread(_insert_records)
 
                 logger.info(f"Inserted {content_type} {item} into Milvus. Done.")
 
@@ -363,7 +362,6 @@ async def delete_file(self, db_id: str, file_id: str) -> None:
                     def _delete_from_milvus():
                         try:
                             collection.delete(expr)
-                            collection.flush()
                             logger.info(f"Deleted chunks for file {file_id} from Milvus")
                         except Exception as e:
                             logger.error(f"Error deleting file {file_id} from Milvus: {e}")