28 lines
508 B
Python
28 lines
508 B
Python
# 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"},
|
|
}
|
|
|
|
celery.conf.task_default_queue = "default"
|