Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
NickM-27 committed Jul 11, 2023
1 parent d7d65be commit 570e1fc
Showing 1 changed file with 8 additions and 4 deletions.
12 changes: 8 additions & 4 deletions frigate/app.py
Expand Up @@ -200,10 +200,12 @@ def set_log_levels(self) -> None:
def init_queues(self) -> None:
# Queues for clip processing
self.event_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
DEFAULT_QUEUE_BUFFER_SIZE
* sum(camera.enabled for camera in self.config.cameras.values())
)
self.event_processed_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
DEFAULT_QUEUE_BUFFER_SIZE
* sum(camera.enabled for camera in self.config.cameras.values())
)
self.video_output_queue: Queue = mp.Queue(
maxsize=sum(camera.enabled for camera in self.config.cameras.values()) * 2
Expand All @@ -216,12 +218,14 @@ def init_queues(self) -> None:

# Queue for recordings info
self.recordings_info_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
DEFAULT_QUEUE_BUFFER_SIZE
* sum(camera.enabled for camera in self.config.cameras.values())
)

# Queue for timeline events
self.timeline_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
DEFAULT_QUEUE_BUFFER_SIZE
* sum(camera.enabled for camera in self.config.cameras.values())
)

def init_database(self) -> None:
Expand Down

0 comments on commit 570e1fc

Please sign in to comment.