import os
from celery import Celery

CELERY_BROKER = os.getenv("CELERY_BROKER_URL", "redis://redis:6379/0")
CELERY_BACKEND = os.getenv("CELERY_RESULT_BACKEND", "redis://redis:6379/0")

celery = Celery(
    "extractor_tasks",
    broker=CELERY_BROKER,
    backend=CELERY_BACKEND,
    include=["routes.mcq_extraction"]  # <- just the module name
)

celery.conf.update(
    task_serializer='json',
    accept_content=['json'],
    result_serializer='json',
    timezone='UTC',
    enable_utc=True,
)