From 50b630aee9a2f0adc56822a86f176537c76d109f Mon Sep 17 00:00:00 2001 From: dustinface <35775977+xdustinface@users.noreply.github.com> Date: Wed, 9 Nov 2022 21:57:59 +0100 Subject: [PATCH] server: Don't pass the queue into `WSChiaConnection._wait_and_retry` (#13877) --- chia/server/ws_connection.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/chia/server/ws_connection.py b/chia/server/ws_connection.py index f82c20132c..4f8b663f56 100644 --- a/chia/server/ws_connection.py +++ b/chia/server/ws_connection.py @@ -383,10 +383,10 @@ class WSChiaConnection: for message in messages: await self.outgoing_queue.put(message) - async def _wait_and_retry(self, msg: Message, queue: asyncio.Queue): + async def _wait_and_retry(self, msg: Message): try: await asyncio.sleep(1) - await queue.put(msg) + await self.outgoing_queue.put(msg) except Exception as e: self.log.debug(f"Exception {e} while waiting to retry sending rate limited message") return None @@ -406,7 +406,7 @@ class WSChiaConnection: # TODO: fix this special case. This function has rate limits which are too low. if ProtocolMessageTypes(message.type) != ProtocolMessageTypes.respond_peers: - asyncio.create_task(self._wait_and_retry(message, self.outgoing_queue)) + asyncio.create_task(self._wait_and_retry(message)) return None else: