🚧 fix(wip): ack_sync timeout testing

Prismadic · Jan 23, 2024 · ab6caaf · ab6caaf
1 parent 36e3cac
commit ab6caaf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/magnet/ize/memory.py b/magnet/ize/memory.py
@@ -81,10 +81,10 @@ async def index(self, payload, msg, verbose=False, field=None, charge=False, ins
                         if field:
                             _f('info', f'sending payload\n{payload}') if verbose else None
                             await self.field.pulse(payload)
-                    await msg.ack_sync()
+                    await msg.ack_sync(timeout=15)
                 else:
                     _f('warn', f'embedding exists already\n{payload.text}') if verbose else None
-                    await msg.ack_sync()
+                    await msg.ack_sync(timeout=15)
             except Exception as e:
                 await msg.term()
                 _f('fatal', e)