From 6acb452cfa23fa26858129c093397dcfbc8ad63b Mon Sep 17 00:00:00 2001 From: michael Date: Fri, 26 Dec 2025 11:39:34 -0600 Subject: [PATCH] fix: add render queue to Celery worker MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The accessible video render task was being dispatched to the 'render' queue but no worker was listening to it. Added 'render' to: - Dockerfile CMD args for worker queue list - celery_worker.py import and log message 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- backend/Dockerfile | 2 +- backend/celery_worker.py | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/backend/Dockerfile b/backend/Dockerfile index fa0a052..35f52d2 100644 --- a/backend/Dockerfile +++ b/backend/Dockerfile @@ -134,7 +134,7 @@ ENTRYPOINT ["tini", "--"] # Start Celery worker listening to all queues # --concurrency=4 for 4 worker processes (adjust based on CPU cores available) CMD ["celery", "-A", "celery_worker", "worker", \ - "-Q", "default,ingest,notify", \ + "-Q", "default,ingest,notify,render", \ "--loglevel=info", \ "--concurrency=4", \ "--max-tasks-per-child=100"] diff --git a/backend/celery_worker.py b/backend/celery_worker.py index 057d75c..b3c6a03 100644 --- a/backend/celery_worker.py +++ b/backend/celery_worker.py @@ -24,12 +24,13 @@ logger.info("Starting Celery worker with structured logging") # Import task modules to register them from app.tasks import ingest_and_ai from app.tasks import translate_and_synthesize +from app.tasks import render_accessible_video # 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") +logger.info(f"Worker listening to queues: default,ingest,notify,render") # Specifically check for our translation task if 'app.tasks.translate_and_synthesize.translate_and_synthesize_task' in celery_app.tasks: