app/workers/celery_app.py

try:
    from celery import Celery
    from app.config import settings

    celery_app = Celery(
        "bio_nexus",
        broker=settings.CELERY_BROKER_URL,
        backend=settings.CELERY_RESULT_BACKEND,
    )

    celery_app.conf.update(
        task_serializer="json",
        accept_content=["json"],
        result_serializer="json",
        timezone="UTC",
        enable_utc=True,
        task_track_started=True,
        task_acks_late=True,
        worker_prefetch_multiplier=1,
    )

    import redis
    r = redis.from_url(settings.REDIS_URL)
    r.ping()
    r.close()
except Exception:
    celery_app = None