From 6c08b3f695cce1d608ac594990d9e04fc9507837 Mon Sep 17 00:00:00 2001 From: Konstantinos Panayiotou Date: Fri, 20 Dec 2024 15:39:42 +0200 Subject: [PATCH] Remove Redis wait_for_msg logging on timeout --- commlib/transports/redis.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/commlib/transports/redis.py b/commlib/transports/redis.py index cfdd879..11dc8d6 100644 --- a/commlib/transports/redis.py +++ b/commlib/transports/redis.py @@ -187,7 +187,7 @@ def wait_for_msg(self, queue_name: str, timeout=10): if self._compression != CompressionType.NO_COMPRESSION: payload = deflate(payload) except Exception: - self.log.error(f"Timeout after {timeout} seconds waiting for message") + # self.log.warning(f"Timeout after {timeout} seconds waiting for message") msgq = "" payload = None return msgq, payload @@ -246,8 +246,6 @@ def _on_request_internal(self, data: Dict[str, Any], header: Dict[str, Any]): def run_forever(self): self._transport.start() - while not self._transport.is_connected: - time.sleep(0.01) if self._transport.queue_exists(self._rpc_name): self._transport.delete_queue(self._rpc_name) while True: