Fix redis client

weni-ai · Dec 11, 2024 · fa5f482 · fa5f482
1 parent 93a1048
commit fa5f482
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/router/tasks/tasks.py b/router/tasks/tasks.py
@@ -32,7 +32,8 @@
 @celery_app.task(bind=True)
 def start_route(self, message: Dict) -> bool:  # pragma: no cover
 
-    redis_client = Redis(host=settings.REDIS_HOST, port=6379, db=0)  # Use Redis host from settings
+    # Initialize Redis client using the REDIS_URL from settings
+    redis_client = Redis.from_url(settings.REDIS_URL)
 
     print(f"[+ Message received: {message} +]")