from asyncio import Event from algo.model_manager import AlgoModelExec from algo.stream_loader import OpenCVStreamLoad from common.device_status_manager import DeviceStatusManager from common.global_logger import logger from entity.device import Device from ultralytics import YOLO from tcp.tcp_manager import TcpManager class BaseSceneHandler: def __init__(self, device: Device, thread_id: str, tcp_manager: TcpManager, main_loop ): self.device = device self.thread_id = thread_id self.tcp_manager =tcp_manager self.main_loop = main_loop def stop_task(self): pass def run(self): pass