From f943503f546ba521c0c3ced8e29931cffe48e149 Mon Sep 17 00:00:00 2001 From: pacnpal <183241239+pacnpal@users.noreply.github.com> Date: Fri, 15 Nov 2024 02:51:20 +0000 Subject: [PATCH] logging --- videoarchiver/enhanced_queue.py | 2 ++ videoarchiver/processor.py | 3 +++ 2 files changed, 5 insertions(+) diff --git a/videoarchiver/enhanced_queue.py b/videoarchiver/enhanced_queue.py index ffab3d2..1cd8e58 100644 --- a/videoarchiver/enhanced_queue.py +++ b/videoarchiver/enhanced_queue.py @@ -239,6 +239,7 @@ class EnhancedVideoQueueManager: Args: processor: A callable that takes a QueueItem and returns a tuple of (success: bool, error: Optional[str]) """ + logger.info("Queue processor started and waiting for items...") while True: try: # Get next item from queue @@ -249,6 +250,7 @@ class EnhancedVideoQueueManager: self._processing[item.url] = item item.status = "processing" item.processing_time = time.time() + logger.info(f"Processing queue item: {item.url}") if not item: await asyncio.sleep(1) diff --git a/videoarchiver/processor.py b/videoarchiver/processor.py index cd39393..15cd7fa 100644 --- a/videoarchiver/processor.py +++ b/videoarchiver/processor.py @@ -45,10 +45,13 @@ class VideoProcessor: self._failed_downloads_lock = asyncio.Lock() # Start queue processing + logger.info("Starting video processing queue...") self._queue_task = asyncio.create_task(self.queue_manager.process_queue(self._process_video)) + logger.info("Video processing queue started successfully") async def _process_video(self, item: Any) -> Tuple[bool, Optional[str]]: """Process a video from the queue""" + logger.info(f"Processing video from queue: {item.url}") try: # Get the message channel = self.bot.get_channel(item.channel_id)