diff --git a/freqtrade/rpc/api_server/api_ws.py b/freqtrade/rpc/api_server/api_ws.py index 46909955d..2f490b8a8 100644 --- a/freqtrade/rpc/api_server/api_ws.py +++ b/freqtrade/rpc/api_server/api_ws.py @@ -1,3 +1,4 @@ +import asyncio import logging from typing import Any, Dict @@ -89,6 +90,8 @@ async def _process_consumer_request( for _, message in analyzed_df.items(): response = WSAnalyzedDFMessage(data=message) await channel.send(response.dict(exclude_none=True)) + # Throttle the messages to 50/s + await asyncio.sleep(0.02) @router.websocket("/message/ws")