From 0834f5552029a8bc2a6a18e64af064f8c7e9d85b Mon Sep 17 00:00:00 2001
From: msramalho <19508417+msramalho@users.noreply.github.com>
Date: Tue, 11 Feb 2025 21:33:02 +0000
Subject: [PATCH] dynamic CELERY_BROKER_URL property in settings

---
 app/shared/settings.py       | 6 +++++-
 app/shared/task_messaging.py | 2 ++
 2 files changed, 7 insertions(+), 1 deletion(-)

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)