From 2f64a086238b383312dd2db9aea104690aac5a8a Mon Sep 17 00:00:00 2001 From: Timothy Pogue Date: Sun, 9 Oct 2022 15:11:58 -0600 Subject: [PATCH] set channel queue maxsize to 32 --- freqtrade/rpc/api_server/ws/channel.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/freqtrade/rpc/api_server/ws/channel.py b/freqtrade/rpc/api_server/ws/channel.py index 8c6c56d6e..91875abfb 100644 --- a/freqtrade/rpc/api_server/ws/channel.py +++ b/freqtrade/rpc/api_server/ws/channel.py @@ -35,7 +35,7 @@ class WebSocketChannel: self._serializer_cls = serializer_cls self._subscriptions: List[str] = [] - self.queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue() + self.queue: asyncio.Queue[Dict[str, Any]] = asyncio.Queue(maxsize=32) self._relay_task = asyncio.create_task(self.relay()) # Internal event to signify a closed websocket