# app/core/queue_manager.py from app.utils.priority_queue_utils import NamedQueueManager queue_manager = NamedQueueManager()