diff --git a/frigate/comms/config_updater.py b/frigate/comms/config_updater.py index 6b35b149e..273103911 100644 --- a/frigate/comms/config_updater.py +++ b/frigate/comms/config_updater.py @@ -21,7 +21,7 @@ class ConfigPublisher: def publish(self, topic: str, payload: any) -> None: """There is no communication back to the processes.""" self.socket.send_string(topic, flags=zmq.SNDMORE) - self.socket.send_json(payload) + self.socket.send_pyobj(payload) def stop(self) -> None: self.stop_event.set() @@ -42,7 +42,7 @@ class ConfigSubscriber: """Returns updated config or None if no update.""" try: topic = self.socket.recv_string(flags=zmq.NOBLOCK) - return (topic, self.socket.recv_json()) + return (topic, self.socket.recv_pyobj()) except zmq.ZMQError: return (None, None)