Only use enabled cameras

blakeblackshear · Jul 11, 2023 · d7d65be · d7d65be
1 parent c4f0b6c
commit d7d65be
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/frigate/app.py b/frigate/app.py
@@ -200,28 +200,28 @@ 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 * len(self.config.cameras.keys())
+            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 * len(self.config.cameras.keys())
+            DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
         )
         self.video_output_queue: Queue = mp.Queue(
-            maxsize=len(self.config.cameras.keys()) * 2
+            maxsize=sum(camera.enabled for camera in self.config.cameras.values()) * 2
         )
 
         # Queue for cameras to push tracked objects to
         self.detected_frames_queue: Queue = mp.Queue(
-            maxsize=len(self.config.cameras.keys()) * 2
+            maxsize=sum(camera.enabled for camera in self.config.cameras.values()) * 2
         )
 
         # Queue for recordings info
         self.recordings_info_queue: Queue = ff.Queue(
-            DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys())
+            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 * len(self.config.cameras.keys())
+            DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
         )
 
     def init_database(self) -> None: