Move image upscaling to Celery queue for better reliability

This commit is contained in:
DJP 2025-12-10 21:35:42 -05:00
parent 7aeb2426ed
commit 892e5faec4

View file

@ -23,7 +23,7 @@ from app.services import (
markdown_tools,
sound_effects
)
from app.workers.tasks import process_video_generation
from app.workers.tasks import process_video_generation, process_image_upscaling
router = APIRouter()
@ -347,7 +347,8 @@ async def upscale_image(
db.commit()
db.refresh(job)
background_tasks.add_task(image_upscaler.upscale, str(job.id))
# Offload to Celery Worker (Redis) for scalability
process_image_upscaling.delay(str(job.id))
return job_response(job)