Add more to catch

frigate/embeddings/onnx/face_embedding.py

@@ -6,6 +6,7 @@ import os
 import numpy as np
 
 from frigate.const import MODEL_CACHE_DIR
+from frigate.log import redirect_stdout_to_logpipe
 from frigate.util.downloader import ModelDownloader
 
 from .base_embedding import BaseEmbedding
@@ -53,6 +54,7 @@ class FaceNetEmbedding(BaseEmbedding):
             self._load_model_and_utils()
             logger.debug(f"models are already downloaded for {self.model_name}")
 
+    @redirect_stdout_to_logpipe(__name__, logging.DEBUG)
     def _load_model_and_utils(self):
         if self.runner is None:
             if self.downloader:

frigate/events/audio.py

@@ -37,7 +37,7 @@ from frigate.data_processing.real_time.audio_transcription import (
     AudioTranscriptionRealTimeProcessor,
 )
 from frigate.ffmpeg_presets import parse_preset_input
-from frigate.log import LogPipe
+from frigate.log import LogPipe, redirect_stdout_to_logpipe
 from frigate.object_detection.base import load_labels
 from frigate.util.builtin import get_ffmpeg_arg_list
 from frigate.util.process import FrigateProcess
@@ -423,6 +423,7 @@ class AudioEventMaintainer(threading.Thread):
 
 
 class AudioTfl:
+    @redirect_stdout_to_logpipe(__name__, logging.DEBUG)
     def __init__(self, stop_event: threading.Event, num_threads=2):
         self.stop_event = stop_event
         self.num_threads = num_threads

frigate/log.py

@@ -142,7 +142,7 @@ def redirect_stdout_to_logpipe(log_name: str, level: int):
     def decorator(func):
         @wraps(func)
         def wrapper(*args, **kwargs):
-            current_log_pipe = LogPipe()
+            current_log_pipe = LogPipe(log_name, level)
 
             old_stdout = sys.stdout
             old_stderr = sys.stderr