fix: reduce consumer poll timeout from 2000ms to 100ms

This commit is contained in:
Sreeram Venkatasubramanian 2026-04-07 14:19:59 +05:30
parent 8f18ba0257
commit f5bc2d1c83
2 changed files with 36 additions and 1 deletions

View file

@ -160,7 +160,7 @@ class Consumer:
try:
msg = await asyncio.to_thread(
self.consumer.receive,
timeout_millis=2000
timeout_millis=100
)
except Exception as e:
# Handle timeout from any backend