Merge pull request #478 from LACMTA:2023-api-optimization

Refactor sleep durations in websocket_endpoint function
LACMTA · Feb 3, 2024 · 33e6290 · 33e6290
2 parents 01a807f + f47148e
commit 33e6290
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fastapi/app/main.py b/fastapi/app/main.py
@@ -539,7 +539,7 @@ async def reader(channel: aioredis.client.PubSub):
                                         await websocket.send_text(json.dumps(item))
                                 except Exception as e:
                                     await websocket.send_text(f"Error: {str(e)}")
-                        await asyncio.sleep(3)
+                        await asyncio.sleep(1.5)
                 except asyncio.TimeoutError:
                     pass