from celery import Celery

from config import config


app = Celery('tasks', broker=config.BROKER_URL)
# https://medium.com/@taylorhughes/three-quick-tips-from-two-years-with-celery-c05ff9d7f9eb
app.config_from_object({
    "worker_send_task_events": True,
    "task_send_sent_event": True,
    "worker_concurrency": 10,
    "task_soft_time_limit": 3600,
})
app.autodiscover_tasks()