From 73bd3924885a278af3879988d84d03f48df71788 Mon Sep 17 00:00:00 2001 From: Simon Date: Mon, 27 Jan 2025 16:36:19 +0700 Subject: [PATCH] parse unix connection string for redis socket --- backend/task/celery.py | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/backend/task/celery.py b/backend/task/celery.py index b7af1ba0..68e36559 100644 --- a/backend/task/celery.py +++ b/backend/task/celery.py @@ -5,12 +5,21 @@ 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=EnvironmentSettings.REDIS_CON, - backend=EnvironmentSettings.REDIS_CON, - result_extended=True, + "tasks", broker=con_parser(), backend=con_parser(), result_extended=True ) app.config_from_object( "django.conf:settings", namespace=EnvironmentSettings.REDIS_NAME_SPACE