| from celery import Celery | |
| from application.core.settings import settings | |
| def make_celery(app_name=__name__): | |
| celery = Celery(app_name, broker=settings.CELERY_BROKER_URL, backend=settings.CELERY_RESULT_BACKEND) | |
| celery.conf.update(settings) | |
| return celery | |
| celery = make_celery() | |