From 09d53597255dbf64662092f181f74feb32d7d55b Mon Sep 17 00:00:00 2001 From: giles Date: Tue, 3 Feb 2026 20:38:37 +0000 Subject: [PATCH] Re-enable GPU queue routing after image rebuild Co-Authored-By: Claude Opus 4.5 --- app/routers/runs.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/app/routers/runs.py b/app/routers/runs.py index cb762ac..94a4fce 100644 --- a/app/routers/runs.py +++ b/app/routers/runs.py @@ -227,11 +227,7 @@ async def create_stream_run( logger.warning(f"Failed to store recipe in cache: {e}") # Continue anyway - run will still work, just won't appear in /recipes - # Submit Celery task - uses GPU queue if NVIDIA available, otherwise default - # Note: GPU worker needs image rebuild for IPFS HLS support, using default for now - import os - use_gpu_queue = os.environ.get("USE_GPU_QUEUE", "false").lower() == "true" - task_queue = 'gpu' if use_gpu_queue else None # None = default queue + # Submit Celery task to GPU queue for hardware-accelerated rendering task = run_stream.apply_async( kwargs=dict( run_id=run_id, @@ -243,7 +239,7 @@ async def create_stream_run( sources_sexp=request.sources_sexp, audio_sexp=request.audio_sexp, ), - queue=task_queue, + queue='gpu', ) # Store in database for durability