from __future__ import annotations

from celery import Celery

from app.config import get_settings

settings = get_settings()

celery_app = Celery(
    "campaign_port",
    broker=settings.celery_broker_url,
    backend=settings.celery_result_backend,
)

celery_app.conf.task_default_queue = settings.queue_first_campaign

# Register tasks
import app.workers.tasks  # noqa: E402, F401