From 4930eb99ad84a7197320387472e14cfd0e512839 Mon Sep 17 00:00:00 2001 From: giles Date: Tue, 3 Feb 2026 20:25:50 +0000 Subject: [PATCH] Temp: disable GPU queue for testing IPFS HLS streaming Co-Authored-By: Claude Opus 4.5 --- app/routers/runs.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/app/routers/runs.py b/app/routers/runs.py index 94a4fce..cb762ac 100644 --- a/app/routers/runs.py +++ b/app/routers/runs.py @@ -227,7 +227,11 @@ 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 to GPU queue for hardware-accelerated rendering + # 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 task = run_stream.apply_async( kwargs=dict( run_id=run_id, @@ -239,7 +243,7 @@ async def create_stream_run( sources_sexp=request.sources_sexp, audio_sexp=request.audio_sexp, ), - queue='gpu', + queue=task_queue, ) # Store in database for durability