administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-03 01:35:22 +03:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Fix typo and improve logging

Browse Source
This commit is contained in:
Nick Mowen 2022-09-26 10:42:49 -06:00
parent 1396cd7b44
commit 310aa0d3f0
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
frigate/storage.py
View File

@ -142,12 +142,13 @@ class StorageMaintainer(threading.Thread):
.objects() .objects()
) )
deleted_recordings: set[str] = self.deleted_recordings( deleted_recordings: set[str] = self.delete_recording_segments(
recordings, retained_events, segment_count recordings, retained_events, segment_count
) )
# check if 2 hours of segments were deleted from the 24 retrieved # check if 2 hours of segments were deleted from the 24 retrieved
if len(deleted_recordings) < segment_count: if len(deleted_recordings) < segment_count:
logger.debug(f"segment target of {segment_count} > {len(deleted_recordings)}, pulling all non-retained recordings")
# get the rest of the recording segments to look through # get the rest of the recording segments to look through
recordings: Recordings = ( recordings: Recordings = (
Recordings.select() Recordings.select()
@ -161,6 +162,7 @@ class StorageMaintainer(threading.Thread):
# check if still 2 hour quota still not meant # check if still 2 hour quota still not meant
if len(deleted_recordings) < segment_count: if len(deleted_recordings) < segment_count:
logger.debug(f"segment target of {segment_count} > {len(deleted_recordings)}, pulling all recordings")
recordings: Recordings = ( recordings: Recordings = (
Recordings.select() Recordings.select()
.where(Recordings.camera == camera) .where(Recordings.camera == camera)
@ -184,7 +186,7 @@ class StorageMaintainer(threading.Thread):
logger.debug(f"End camera: {camera}.") logger.debug(f"End camera: {camera}.")
logger.debug("End all cameras.") logger.debug("End all cameras.")
logger.debug("End expire recordings (new).") logger.debug("End storage cleanup.")
def run(self): def run(self):
# Check storage consumption every 5 minutes # Check storage consumption every 5 minutes