29 lines
728 B
Python
29 lines
728 B
Python
"""initiate celery"""
|
|
|
|
import os
|
|
|
|
from celery import Celery
|
|
from common.src.env_settings import EnvironmentSettings
|
|
|
|
|
|
def con_parser():
|
|
"""allow for unix socket parsing"""
|
|
redis_con = EnvironmentSettings.REDIS_CON
|
|
if redis_con.startswith("unix://"):
|
|
redis_con = EnvironmentSettings.REDIS_CON.replace(
|
|
"unix://", "redis+socket://", 1
|
|
)
|
|
|
|
return redis_con
|
|
|
|
|
|
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings")
|
|
app = Celery(
|
|
"tasks", broker=con_parser(), backend=con_parser(), result_extended=True
|
|
)
|
|
app.config_from_object(
|
|
"django.conf:settings", namespace=EnvironmentSettings.REDIS_NAME_SPACE
|
|
)
|
|
app.autodiscover_tasks()
|
|
app.conf.timezone = EnvironmentSettings.TZ
|