# All comments are in English.

from celery import Celery
import os

redis_url = os.getenv("REDIS_URL", "redis://redis:6379/0")

celery = Celery(
    "app",
    broker=redis_url,
    backend=redis_url,
)

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

celery.conf.task_routes = {
    "tasks.admin_*": {"queue": "admin"},
    "tasks.*": {"queue": "default"},
    "tasks.system_admin_*": {"queue": "system_admin"},
    "tasks.corp_admin_*": {"queue": "corp_admin"},
    "tasks.user_*": {"queue": "user_default"},
}



celery.conf.task_default_queue = "default"