Skip to content

Commit ab6caaf

Browse files
committed
🚧 fix(wip): ack_sync timeout testing
1 parent 36e3cac commit ab6caaf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

magnet/ize/memory.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -81,10 +81,10 @@ async def index(self, payload, msg, verbose=False, field=None, charge=False, ins
8181
if field:
8282
_f('info', f'sending payload\n{payload}') if verbose else None
8383
await self.field.pulse(payload)
84-
await msg.ack_sync()
84+
await msg.ack_sync(timeout=15)
8585
else:
8686
_f('warn', f'embedding exists already\n{payload.text}') if verbose else None
87-
await msg.ack_sync()
87+
await msg.ack_sync(timeout=15)
8888
except Exception as e:
8989
await msg.term()
9090
_f('fatal', e)

0 commit comments

Comments
 (0)