tubearchivist/tubearchivist
1
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist.git synced 2025-03-14 09:50:12 +00:00
Code Issues Projects Releases Wiki Activity

parse unix connection string for redis socket

Browse Source
This commit is contained in:
Simon 2025-01-27 16:36:19 +07:00
parent a68798842b
commit 73bd392488
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
backend/task/celery.py
View File

@ -5,12 +5,21 @@ import os
from celery import Celery from celery import Celery
from common.src.env_settings import EnvironmentSettings 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") os.environ.setdefault("DJANGO_SETTINGS_MODULE", "config.settings")
app = Celery( app = Celery(
"tasks", "tasks", broker=con_parser(), backend=con_parser(), result_extended=True
broker=EnvironmentSettings.REDIS_CON,
backend=EnvironmentSettings.REDIS_CON,
result_extended=True,
) )
app.config_from_object( app.config_from_object(
"django.conf:settings", namespace=EnvironmentSettings.REDIS_NAME_SPACE "django.conf:settings", namespace=EnvironmentSettings.REDIS_NAME_SPACE