fix(processor): add fallback to absolute imports in reactions.py

This commit is contained in:
pacnpal
2024-11-17 23:06:22 +00:00
parent c944d4d2e1
commit 6647c93a44
3 changed files with 18 additions and 5 deletions

View File

@@ -15,6 +15,7 @@ modules_to_reload = [
".processor.core", ".processor.core",
".processor.queue_processor", ".processor.queue_processor",
".queue", ".queue",
".queue.types", # Added types module
".queue.models", ".queue.models",
".queue.manager", ".queue.manager",
".queue.cleaners", ".queue.cleaners",

View File

@@ -36,6 +36,7 @@ try:
) )
from .message_handler import MessageHandler from .message_handler import MessageHandler
from .queue_handler import QueueHandler from .queue_handler import QueueHandler
from .queue_processor import QueueProcessor # Added import
from .reactions import ( from .reactions import (
handle_archived_reaction, handle_archived_reaction,
update_queue_position_reaction, update_queue_position_reaction,
@@ -76,6 +77,7 @@ except ImportError:
) )
from videoarchiver.processor.message_handler import MessageHandler from videoarchiver.processor.message_handler import MessageHandler
from videoarchiver.processor.queue_handler import QueueHandler from videoarchiver.processor.queue_handler import QueueHandler
from videoarchiver.processor.queue_processor import QueueProcessor # Added import
from videoarchiver.processor.reactions import ( from videoarchiver.processor.reactions import (
handle_archived_reaction, handle_archived_reaction,
update_queue_position_reaction, update_queue_position_reaction,
@@ -90,6 +92,7 @@ __all__ = [
"VideoProcessor", "VideoProcessor",
"MessageHandler", "MessageHandler",
"QueueHandler", "QueueHandler",
"QueueProcessor", # Added export
# URL Extraction # URL Extraction
"URLExtractor", "URLExtractor",
"URLMetadata", "URLMetadata",

View File

@@ -1,6 +1,7 @@
"""Queue management package for video processing""" """Queue management package for video processing"""
from .models import QueueItem, QueueMetrics from .models import QueueItem, QueueMetrics
from .types import QueuePriority, ProcessingMetrics
from .manager import EnhancedVideoQueueManager from .manager import EnhancedVideoQueueManager
from .persistence import QueuePersistenceManager, QueueError from .persistence import QueuePersistenceManager, QueueError
from .monitoring import QueueMonitor, MonitoringError from .monitoring import QueueMonitor, MonitoringError
@@ -23,27 +24,35 @@ from ..utils.progress_tracker import ProgressTracker
from ..utils.url_validator import UrlValidator from ..utils.url_validator import UrlValidator
__all__ = [ __all__ = [
# Queue models and types
'QueueItem', 'QueueItem',
'QueueMetrics', 'QueueMetrics',
'QueuePriority',
'ProcessingMetrics',
# Core components
'EnhancedVideoQueueManager', 'EnhancedVideoQueueManager',
'QueuePersistenceManager', 'QueuePersistenceManager',
'QueueMonitor', 'QueueMonitor',
'QueueCleaner', 'QueueCleaner',
'QueueError', 'QueueProcessor',
'MonitoringError', 'HealthChecker',
'CleanupError', # Managers
'RecoveryManager', 'RecoveryManager',
'StateManager', 'StateManager',
'MetricsManager', 'MetricsManager',
'QueueProcessor', # Cleaners
'HealthChecker',
'GuildCleaner', 'GuildCleaner',
'HistoryCleaner', 'HistoryCleaner',
'TrackingCleaner', 'TrackingCleaner',
# Utility handlers
'CompressionHandler', 'CompressionHandler',
'DirectoryManager', 'DirectoryManager',
'DownloadManager', 'DownloadManager',
'FileOperations', 'FileOperations',
'ProgressTracker', 'ProgressTracker',
'UrlValidator', 'UrlValidator',
# Errors
'QueueError',
'MonitoringError',
'CleanupError',
] ]