| 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"] | |
| def process_job(job_id: str) -> str: | |
| return f"Queued job {job_id}. FastAPI background tasks are active by default." | |