feat: missing redis

app/services/scheduler_service.py

@@ -505,8 +505,6 @@ class SchedulerService:
 
     def _redis_conn_params(self) -> dict:
         """Connection parameters for redis.Redis()."""
-        if settings.redis_url:
-            return {"url": settings.redis_url}
         return {
             "host": settings.redis_host,
             "port": settings.redis_port,
@@ -551,12 +549,14 @@ class SchedulerService:
         if ra is None:
             return None
         try:
-            params = self._redis_conn_params()
-            client = ra.Redis(**params, decode_responses=True)
+            if settings.redis_url:
+                client = ra.from_url(settings.redis_url, decode_responses=True)
+            else:
+                client = ra.Redis(**self._redis_conn_params(), decode_responses=True)
             await client.ping()
             logger.info(
                 "Connected to Redis (url=%s)",
-                params.get("url") or f"{settings.redis_host}:{settings.redis_port}",
+                settings.redis_url or f"{settings.redis_host}:{settings.redis_port}",
             )
             return client
         except Exception as exc: