From b166c04cba694125506fb4544494aa70bc74d8e2 Mon Sep 17 00:00:00 2001 From: Matthias Date: Mon, 17 Oct 2022 19:29:30 +0200 Subject: [PATCH] Bring back asyncio.sleep to avoid overwelming the a consumer queue --- freqtrade/rpc/api_server/webserver.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/freqtrade/rpc/api_server/webserver.py b/freqtrade/rpc/api_server/webserver.py index c6639f1a6..4a09fd78e 100644 --- a/freqtrade/rpc/api_server/webserver.py +++ b/freqtrade/rpc/api_server/webserver.py @@ -198,6 +198,10 @@ class ApiServer(RPCHandler): logger.debug(f"Found message of type: {message.get('type')}") # Broadcast it await self._ws_channel_manager.broadcast(message) + # Limit messages per sec. + # Could cause problems with queue size if too low, and + # problems with network traffik if too high. + await asyncio.sleep(0.001) except asyncio.CancelledError: pass