"""Celery: приложение воркера и каркасные задачи."""

from celery import Celery

from app.config import get_settings

settings = get_settings()

celery_app = Celery(
    "synapse",
    broker=settings.redis_url,
    backend=settings.redis_url,
    include=["app.worker.tasks"],
)

celery_app.conf.update(
    task_default_queue="synapse",
    task_track_started=True,
    # TODO(#29): политика ретраев и таймаутов — уточнить при реализации доставок.
    task_acks_late=True,
    worker_prefetch_multiplier=1,
)