app/celery_app.py

from celery import Celery
from app.config import settings

# Allow running without a broker (Queues disabled in Spaces preview)
if settings.CELERY_BROKER_URL:
    celery = Celery(
        "prir",
        broker=settings.CELERY_BROKER_URL,
        backend=settings.CELERY_RESULT_BACKEND or None,
    )
    celery.conf.update(
        task_serializer="json",
        accept_content=["json"],
        result_serializer="json",
        timezone="Asia/Tokyo",
        enable_utc=True,
    )
else:
    # Dummy Celery shim for .delay/.apply_async to fail gracefully
    class _Dummy:
        def task(self, *a, **kw):
            def deco(fn):
                return fn
            return deco
    celery = _Dummy()