diff --git a/backend/celery_worker.py b/backend/celery_worker.py index 40e65b4..fee43c9 100644 --- a/backend/celery_worker.py +++ b/backend/celery_worker.py @@ -26,12 +26,14 @@ from app.tasks import ingest_and_ai from app.tasks import translate_and_synthesize from app.tasks import render_accessible_video from app.tasks import ffmpeg_operations +from app.tasks import whisper_transcribe # Debug: Show registered tasks logger.info(f"Celery app: {celery_app}") logger.info(f"Registered tasks: {list(celery_app.tasks.keys())}") logger.info(f"Task routes: {celery_app.conf.task_routes}") -logger.info(f"Worker listening to queues: default,ingest,notify,render,ffmpeg") +# Note: Actual queue listening is determined by -Q argument passed to celery worker command +logger.info("Task modules loaded. Queues determined by celery -Q argument.") # Specifically check for our translation task if 'app.tasks.translate_and_synthesize.translate_and_synthesize_task' in celery_app.tasks: