We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e124e62 commit df9b493Copy full SHA for df9b493
1 file changed
template/server/messaging.py
@@ -260,9 +260,7 @@ async def _wait_for_result(self, message_id: str):
260
261
while True:
262
try:
263
- output = await asyncio.wait_for(
264
- queue.get(), timeout=KEEPALIVE_INTERVAL
265
- )
+ output = await asyncio.wait_for(queue.get(), timeout=KEEPALIVE_INTERVAL)
266
except asyncio.TimeoutError:
267
# Yield a keepalive so Starlette writes to the socket.
268
# If the client has disconnected, the write fails and
0 commit comments