frigate/app.py

@@ -44,7 +44,6 @@ from frigate.embeddings import EmbeddingsContext, manage_embeddings
 from frigate.events.audio import AudioProcessor
 from frigate.events.cleanup import EventCleanup
 from frigate.events.maintainer import EventProcessor
-from frigate.log import _stop_logging
 from frigate.models import (
     Event,
     Export,
@@ -772,7 +771,4 @@ class FrigateApp:
             shm.close()
             shm.unlink()
 
-        # exit the mp Manager process
-        _stop_logging()
-
         os._exit(os.EX_OK)

frigate/data_processing/real_time/bird.py

@@ -97,9 +97,6 @@ class BirdRealTimeProcessor(RealTimeProcessorApi):
                 line = f.readline()
 
     def process_frame(self, obj_data, frame):
-        if not self.interpreter:
-            return
-
         if obj_data["label"] != "bird":
             return
 

frigate/log.py

@@ -1,4 +1,3 @@
-# In log.py
 import atexit
 import logging
 import multiprocessing as mp
@@ -7,7 +6,6 @@ import sys
 import threading
 from collections import deque
 from logging.handlers import QueueHandler, QueueListener
-from queue import Queue
 from typing import Deque, Optional
 
 from frigate.util.builtin import clean_camera_user_pass
@@ -34,14 +32,12 @@ LOG_HANDLER.addFilter(
 )
 
 log_listener: Optional[QueueListener] = None
-log_queue: Optional[Queue] = None
-manager = None
 
 
 def setup_logging() -> None:
-    global log_listener, log_queue, manager
-    manager = mp.Manager()
-    log_queue = manager.Queue()
+    global log_listener
+
+    log_queue: mp.Queue = mp.Queue()
     log_listener = QueueListener(log_queue, LOG_HANDLER, respect_handler_level=True)
 
     atexit.register(_stop_logging)
@@ -57,13 +53,11 @@ def setup_logging() -> None:
 
 
 def _stop_logging() -> None:
-    global log_listener, manager
+    global log_listener
+
     if log_listener is not None:
         log_listener.stop()
         log_listener = None
-    if manager is not None:
-        manager.shutdown()
-        manager = None
 
 
 # When a multiprocessing.Process exits, python tries to flush stdout and stderr. However, if the