Skip to content

Commit 5e72d88

Browse files
committed
🚧 fix(wip): terminate msg when insert results in fatal error from db
1 parent 9b2151d commit 5e72d88

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

magnet/ize/memory.py

+1
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,7 @@ async def index(self, payload, msg, verbose=False, field=None, charge=False, ins
8686
_f('info', 'embedding exists already') if verbose else None
8787
await msg.ack()
8888
except Exception as e:
89+
await msg.term()
8990
_f('fatal', e)
9091

9192
def search(self, payload, limit=100, cb=None, instruction="Represent this sentence for searching relevant passages: "):

0 commit comments

Comments
 (0)