Mirrors/blakeblackshear.frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2025-07-30 13:48:07 +02:00
Code Issues Projects Releases Wiki Activity

Cleanup recordings updator

Browse Source
This commit is contained in:
Nicolas Mowen 2025-06-06 08:31:09 -06:00
parent cdec93d45a
commit de7238df7f
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
frigate/comms/recordings_updater.py
View File

@ -2,6 +2,7 @@
import logging import logging
from enum import Enum from enum import Enum
from typing import Any
from .zmq_proxy import Publisher, Subscriber from .zmq_proxy import Publisher, Subscriber
@ -19,11 +20,10 @@ class RecordingsDataPublisher(Publisher):
topic_base = "recordings/" topic_base = "recordings/"
def __init__(self, topic: RecordingsDataTypeEnum) -> None: def __init__(self, topic: RecordingsDataTypeEnum) -> None:
topic = topic.value super().__init__(topic.value)
super().__init__(topic)
def publish(self, payload: tuple[str, float]) -> None: def publish(self, payload: Any, sub_topic: str = "") -> None:
super().publish(payload) super().publish(payload, sub_topic)
class RecordingsDataSubscriber(Subscriber): class RecordingsDataSubscriber(Subscriber):
@ -32,5 +32,4 @@ class RecordingsDataSubscriber(Subscriber):
topic_base = "recordings/" topic_base = "recordings/"
def __init__(self, topic: RecordingsDataTypeEnum) -> None: def __init__(self, topic: RecordingsDataTypeEnum) -> None:
topic = topic.value super().__init__(topic.value)
super().__init__(topic)