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

Catch case where no recordings exist for camera

Browse Source
This commit is contained in:
Nick Mowen 2022-09-26 10:45:45 -06:00
parent 310aa0d3f0
commit 6502a52225
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
frigate/storage.py
View File

@ -31,12 +31,12 @@ class StorageMaintainer(threading.Thread):
for camera in self.config.cameras.keys(): for camera in self.config.cameras.keys():
# get average of non-zero segment sizes to ignore segment with no value # get average of non-zero segment sizes to ignore segment with no value
avg_segment_size = round( segment_query = (
Recordings.select(fn.AVG(Recordings.segment_size)) Recordings.select(fn.AVG(Recordings.segment_size))
.where(Recordings.camera == camera, Recordings.segment_size != 0) .where(Recordings.camera == camera, Recordings.segment_size != 0)
.scalar(), .scalar()
2,
) )
avg_segment_size = round(segment_query, 2) if segment_query else 0
# get average of an hour using the average segment size # get average of an hour using the average segment size
segment_duration = int( segment_duration = int(
@ -148,7 +148,9 @@ class StorageMaintainer(threading.Thread):
# 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") 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()
@ -162,7 +164,9 @@ 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") 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)