Fix typing

This commit is contained in:
Nicolas Mowen 2025-06-12 09:45:17 -06:00
parent 1ac655bc6d
commit 270d8f14c7
3 changed files with 7 additions and 4 deletions

View File

@ -6,6 +6,7 @@ import os
import shutil import shutil
import threading import threading
from multiprocessing import Queue from multiprocessing import Queue
from multiprocessing.managers import DictProxy
from multiprocessing.synchronize import Event as MpEvent from multiprocessing.synchronize import Event as MpEvent
from frigate.camera import CameraMetrics, PTZMetrics from frigate.camera import CameraMetrics, PTZMetrics
@ -32,7 +33,7 @@ class CameraMaintainer(threading.Thread):
config: FrigateConfig, config: FrigateConfig,
detection_queue: Queue, detection_queue: Queue,
detected_frames_queue: Queue, detected_frames_queue: Queue,
camera_metrics: dict[str, CameraMetrics], camera_metrics: DictProxy[str, CameraMetrics],
ptz_metrics: dict[str, PTZMetrics], ptz_metrics: dict[str, PTZMetrics],
stop_event: MpEvent, stop_event: MpEvent,
): ):

View File

@ -6,6 +6,7 @@ import random
import string import string
import threading import threading
import time import time
from multiprocessing.managers import DictProxy
from typing import Any, Tuple from typing import Any, Tuple
import numpy as np import numpy as np
@ -83,7 +84,7 @@ class AudioProcessor(util.Process):
self, self,
config: FrigateConfig, config: FrigateConfig,
cameras: list[CameraConfig], cameras: list[CameraConfig],
camera_metrics: dict[str, CameraMetrics], camera_metrics: DictProxy[str, CameraMetrics],
): ):
super().__init__(name="frigate.audio_manager", daemon=True) super().__init__(name="frigate.audio_manager", daemon=True)
@ -146,7 +147,7 @@ class AudioEventMaintainer(threading.Thread):
self, self,
camera: CameraConfig, camera: CameraConfig,
config: FrigateConfig, config: FrigateConfig,
camera_metrics: dict[str, CameraMetrics], camera_metrics: DictProxy[str, CameraMetrics],
audio_transcription_model_runner: AudioTranscriptionModelRunner | None, audio_transcription_model_runner: AudioTranscriptionModelRunner | None,
stop_event: threading.Event, stop_event: threading.Event,
) -> None: ) -> None:

View File

@ -5,6 +5,7 @@ import os
import shutil import shutil
import time import time
from json import JSONDecodeError from json import JSONDecodeError
from multiprocessing.managers import DictProxy
from typing import Any, Optional from typing import Any, Optional
import psutil import psutil
@ -53,7 +54,7 @@ def get_latest_version(config: FrigateConfig) -> str:
def stats_init( def stats_init(
config: FrigateConfig, config: FrigateConfig,
camera_metrics: dict[str, CameraMetrics], camera_metrics: DictProxy[str, CameraMetrics],
embeddings_metrics: DataProcessorMetrics | None, embeddings_metrics: DataProcessorMetrics | None,
detectors: dict[str, ObjectDetectProcess], detectors: dict[str, ObjectDetectProcess],
processes: dict[str, int], processes: dict[str, int],