diff --git a/app/shared/settings.py b/app/shared/settings.py index e962f1d..427de7e 100644 --- a/app/shared/settings.py +++ b/app/shared/settings.py @@ -33,7 +33,11 @@ class Settings(BaseSettings): # redis REDIS_PASSWORD: str = "" - CELERY_BROKER_URL: str = "redis://localhost:6379" + @property + def CELERY_BROKER_URL(self)-> str: + if self.REDIS_PASSWORD: + return f"redis://:{self.REDIS_PASSWORD}@localhost:6379" + return "redis://localhost:6379" REDIS_EXCEPTIONS_CHANNEL: str = "exceptions-channel" # observability diff --git a/app/shared/task_messaging.py b/app/shared/task_messaging.py index 52dcba3..6f57352 100644 --- a/app/shared/task_messaging.py +++ b/app/shared/task_messaging.py @@ -15,4 +15,6 @@ def get_celery(name:str="") -> Celery: def get_redis() -> redis.Redis: + from loguru import logger + logger.debug(get_settings().CELERY_BROKER_URL) return redis.Redis.from_url(get_settings().CELERY_BROKER_URL)