From ad8a4e3dbe0d5fa6116339cf325d436cf7960976 Mon Sep 17 00:00:00 2001 From: pacnpal <183241239+pacnpal@users.noreply.github.com> Date: Sun, 17 Nov 2024 20:39:12 +0000 Subject: [PATCH] import fix --- videoarchiver/core/component_manager.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/videoarchiver/core/component_manager.py b/videoarchiver/core/component_manager.py index f9c8eaa..fd350f3 100644 --- a/videoarchiver/core/component_manager.py +++ b/videoarchiver/core/component_manager.py @@ -21,9 +21,9 @@ from pathlib import Path import importlib from ..utils.exceptions import ComponentError, ErrorContext, ErrorSeverity -from ..utils.path_manager import ensure_directory +from ..utils.path_manager import PathManager from ..config_manager import ConfigManager -from ..processor.core import Processor +from ..processor.core import VideoProcessor from ..queue.manager import EnhancedVideoQueueManager from ..ffmpeg.ffmpeg_manager import FFmpegManager @@ -281,7 +281,7 @@ class ComponentManager: CORE_COMPONENTS: ClassVar[Dict[str, Tuple[Type[Any], Set[str]]]] = { "config_manager": (ConfigManager, set()), - "processor": (Processor, {"config_manager"}), + "processor": (VideoProcessor, {"config_manager"}), "queue_manager": (EnhancedVideoQueueManager, {"config_manager"}), "ffmpeg_mgr": (FFmpegManager, set()), } @@ -291,6 +291,7 @@ class ComponentManager: self._components: Dict[str, Component] = {} self.tracker = ComponentTracker() self.dependency_manager = DependencyManager() + self.path_manager = PathManager() # Create an instance of PathManager def register( self, @@ -451,8 +452,8 @@ class ComponentManager: download_dir = data_dir / "downloads" # Ensure directories exist - await ensure_directory(data_dir) - await ensure_directory(download_dir) + await self.path_manager.ensure_directory(data_dir) + await self.path_manager.ensure_directory(download_dir) # Register paths self.register("data_path", data_dir)