Skip to content

Commit 7e09b25

Browse files
committed
⚡️ fix(perf): flush not needed every insert per docs
1 parent c7a5cb7 commit 7e09b25

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

magnet/ize/memory.py

+1-2
Original file line numberDiff line numberDiff line change
@@ -69,8 +69,7 @@ async def index(self, payload, msg, verbose=False, field=None, charge=False, ins
6969
self.db.collection.insert([
7070
[payload.document], [payload.text], [payload.embedding]
7171
])
72-
self.db.collection.flush(collection_name_array=[
73-
self.config['INDEX']])
72+
# 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.
7473
if charge:
7574
payload = EmbeddingPayload(
7675
model=self.config['MODEL'],

0 commit comments

Comments
 (0)