administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2025-12-09 06:45:40 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

listen to correct topic in embeddings maintainer

Browse Source
This commit is contained in:
Josh Hawkins 2025-09-26 16:59:55 -05:00
parent 8839f735f4
commit 36804de391
1 changed files with 19 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
frigate/embeddings/maintainer.py
View File

@ -524,20 +524,30 @@ class EmbeddingMaintainer(threading.Thread):
def _process_recordings_updates(self) -> None:
"""Process recordings updates."""
while True:
recordings_data = self.recordings_subscriber.check_for_update()
update = self.recordings_subscriber.check_for_update()
if recordings_data == None:
if not update:
break
camera, recordings_available_through_timestamp = recordings_data
(raw_topic, payload) = update
self.recordings_available_through[camera] = (
recordings_available_through_timestamp
)
if not raw_topic or not payload:
break
logger.debug(
f"{camera} now has recordings available through {recordings_available_through_timestamp}"
)
topic = str(raw_topic)
if topic.endswith(
RecordingsDataTypeEnum.recordings_available_through.value
):
camera, recordings_available_through_timestamp = payload
self.recordings_available_through[camera] = (
recordings_available_through_timestamp
)
logger.debug(
f"{camera} now has recordings available through {recordings_available_through_timestamp}"
)
def _process_review_updates(self) -> None:
"""Process review updates."""