⚡️ fix(perf): flush not needed every insert per docs

Prismadic · Mar 8, 2024 · 7e09b25 · 7e09b25
1 parent c7a5cb7
commit 7e09b25
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/magnet/ize/memory.py b/magnet/ize/memory.py
@@ -69,8 +69,7 @@ async def index(self, payload, msg, verbose=False, field=None, charge=False, ins
                 self.db.collection.insert([
                     [payload.document], [payload.text], [payload.embedding]
                 ])
-                self.db.collection.flush(collection_name_array=[
-                                        self.config['INDEX']])
+                # self.db.collection.flush(collection_name_array=[self.config['INDEX']]) # https://milvus.io/docs/v1.1.1/flush_python.md#:~:text=Milvus%20also%20performs%20an%20automatic,fixed%20interval%20(1%20second).&text=After%20calling%20delete%20%2C%20you%20can,data%20is%20no%20longer%20recoverable.
                 if charge:
                     payload = EmbeddingPayload(
                         model=self.config['MODEL'],