administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-05-05 04:57:42 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

use lower default timeout

Browse Source
This commit is contained in:
Josh Hawkins 2025-04-30 09:15:56 -05:00
parent 9a415e1fc9
commit ba1c9c60a5
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
frigate/embeddings/maintainer.py
View File

@ -231,7 +231,7 @@ class EmbeddingMaintainer(threading.Thread):
def _process_updates(self) -> None: def _process_updates(self) -> None:
"""Process event updates""" """Process event updates"""
update = self.event_subscriber.check_for_update(timeout=0.01) update = self.event_subscriber.check_for_update()
if update is None: if update is None:
return return
@ -324,7 +324,7 @@ class EmbeddingMaintainer(threading.Thread):
def _process_finalized(self) -> None: def _process_finalized(self) -> None:
"""Process the end of an event.""" """Process the end of an event."""
while True: while True:
ended = self.event_end_subscriber.check_for_update(timeout=0.01) ended = self.event_end_subscriber.check_for_update()
if ended == None: if ended == None:
break break
@ -420,7 +420,7 @@ class EmbeddingMaintainer(threading.Thread):
def _process_recordings_updates(self) -> None: def _process_recordings_updates(self) -> None:
"""Process recordings updates.""" """Process recordings updates."""
while True: while True:
recordings_data = self.recordings_subscriber.check_for_update(timeout=0.01) recordings_data = self.recordings_subscriber.check_for_update()
if recordings_data == None: if recordings_data == None:
break break
@ -437,7 +437,7 @@ class EmbeddingMaintainer(threading.Thread):
def _process_event_metadata(self): def _process_event_metadata(self):
# Check for regenerate description requests # Check for regenerate description requests
(topic, payload) = self.event_metadata_subscriber.check_for_update(timeout=0.01) (topic, payload) = self.event_metadata_subscriber.check_for_update()
if topic is None: if topic is None:
return return
@ -451,7 +451,7 @@ class EmbeddingMaintainer(threading.Thread):
def _process_dedicated_lpr(self) -> None: def _process_dedicated_lpr(self) -> None:
"""Process event updates""" """Process event updates"""
(topic, data) = self.detection_subscriber.check_for_update(timeout=0.01) (topic, data) = self.detection_subscriber.check_for_update()
if topic is None: if topic is None:
return return