File size: 483 Bytes
dbc3c35 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | from celery import Celery
from app.core.config import get_settings
settings = get_settings()
celery_app = Celery("ai_clip_studio", broker=settings.redis_url, backend=settings.redis_url)
celery_app.conf.task_serializer = "json"
celery_app.conf.result_serializer = "json"
celery_app.conf.accept_content = ["json"]
@celery_app.task(name="pipeline.process_job")
def process_job(job_id: str) -> str:
return f"Queued job {job_id}. FastAPI background tasks are active by default."
|