From 9a415e1fc98cca09d350e6aa5386ce1434ad7fff Mon Sep 17 00:00:00 2001 From: Josh Hawkins <32435876+hawkeye217@users.noreply.github.com> Date: Wed, 30 Apr 2025 09:15:39 -0500 Subject: [PATCH] update default zmq timeout --- frigate/comms/zmq_proxy.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/frigate/comms/zmq_proxy.py b/frigate/comms/zmq_proxy.py index 1661cfcc5b..6a90d6887e 100644 --- a/frigate/comms/zmq_proxy.py +++ b/frigate/comms/zmq_proxy.py @@ -6,6 +6,8 @@ from typing import Optional import zmq +from frigate.const import FAST_QUEUE_TIMEOUT + SOCKET_PUB = "ipc:///tmp/cache/proxy_pub" SOCKET_SUB = "ipc:///tmp/cache/proxy_sub" @@ -77,7 +79,9 @@ class Subscriber: self.socket.setsockopt_string(zmq.SUBSCRIBE, self.topic) self.socket.connect(SOCKET_SUB) - def check_for_update(self, timeout: float = 1) -> Optional[tuple[str, any]]: + def check_for_update( + self, timeout: float = FAST_QUEUE_TIMEOUT + ) -> Optional[tuple[str, any]]: """Returns message or None if no update.""" try: has_update, _, _ = zmq.select([self.socket], [], [], timeout)