import os
from celery import Celery
from dotenv import load_dotenv

load_dotenv()

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

celery = Celery(
    "tasks",
    broker=CELERY_BROKER,
    backend=CELERY_BACKEND,
    include=[
        "routes.mcq_extraction",
        "Video_generation.video_main",   # 👈 add new pipeline module
        "Video_generation.Video_sync",
        "Video_generation.ppt_pro",
        "Video_generation.audio_conversion",
        "Video_generation.Content_creator",
        "Video_generation.MCQ_creator",
        "Video_generation.mcq_ppt_generator",
    ]
)

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