ok

app/services/scheduler_service.py

@@ -6,6 +6,7 @@ import json
 import re
 import secrets
 import uuid
+from urllib.parse import urlparse
 from datetime import UTC, datetime, timedelta
 from enum import Enum
 from typing import Any
@@ -502,27 +503,60 @@ class SchedulerService:
     # Redis connection management
     # -----------------------------------------------------------------------
 
+    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,
+            "password": settings.redis_password or None,
+            "db": settings.redis_db,
+            "ssl": settings.redis_ssl,
+            "socket_timeout": settings.redis_socket_timeout,
+            "socket_connect_timeout": settings.redis_socket_connect_timeout,
+            "retry_on_timeout": settings.redis_retry_on_timeout,
+            "health_check_interval": settings.redis_health_check_interval,
+        }
+
+    def _redis_jobstore_params(self) -> dict:
+        """Connection parameters for RedisJobStore (does not accept url)."""
+        if settings.redis_url:
+            parsed = urlparse(settings.redis_url)
+            return {
+                "host": parsed.hostname or settings.redis_host,
+                "port": parsed.port or settings.redis_port,
+                "password": parsed.password or settings.redis_password or None,
+                "db": int(parsed.path.lstrip("/")) if parsed.path and parsed.path != "/" else settings.redis_db,
+                "ssl": parsed.scheme in ("rediss", "redis+ssl"),
+                "socket_timeout": settings.redis_socket_timeout,
+                "socket_connect_timeout": settings.redis_socket_connect_timeout,
+                "retry_on_timeout": settings.redis_retry_on_timeout,
+                "health_check_interval": settings.redis_health_check_interval,
+            }
+        return {
+            "host": settings.redis_host,
+            "port": settings.redis_port,
+            "password": settings.redis_password or None,
+            "db": settings.redis_db,
+            "ssl": settings.redis_ssl,
+            "socket_timeout": settings.redis_socket_timeout,
+            "socket_connect_timeout": settings.redis_socket_connect_timeout,
+            "retry_on_timeout": settings.redis_retry_on_timeout,
+            "health_check_interval": settings.redis_health_check_interval,
+        }
+
     async def _connect_async_redis(self) -> Any:
         ra = _get_redis_asyncio()
         if ra is None:
             return None
         try:
-            client = ra.Redis(
-                host=settings.redis_host,
-                port=settings.redis_port,
-                password=settings.redis_password or None,
-                db=settings.redis_db,
-                ssl=settings.redis_ssl,
-                socket_timeout=settings.redis_socket_timeout,
-                socket_connect_timeout=settings.redis_socket_connect_timeout,
-                retry_on_timeout=settings.redis_retry_on_timeout,
-                health_check_interval=settings.redis_health_check_interval,
-                decode_responses=True,
-            )
+            params = self._redis_conn_params()
+            client = ra.Redis(**params, decode_responses=True)
             await client.ping()
             logger.info(
-                "Connected to Redis at %s:%d (db=%d)",
-                settings.redis_host, settings.redis_port, settings.redis_db,
+                "Connected to Redis (url=%s)",
+                params.get("url") or f"{settings.redis_host}:{settings.redis_port}",
             )
             return client
         except Exception as exc:
@@ -533,17 +567,7 @@ class SchedulerService:
         cls = _get_redis_jobstore_cls()
         if cls is None:
             raise RuntimeError("apscheduler[jobstores_redis] not installed")
-        return cls(
-            db=settings.redis_db,
-            host=settings.redis_host,
-            port=settings.redis_port,
-            password=settings.redis_password or None,
-            ssl=settings.redis_ssl,
-            socket_timeout=settings.redis_socket_timeout,
-            socket_connect_timeout=settings.redis_socket_connect_timeout,
-            retry_on_timeout=settings.redis_retry_on_timeout,
-            health_check_interval=settings.redis_health_check_interval,
-        )
+        return cls(**self._redis_jobstore_params())
 
     # -----------------------------------------------------------------------
     # Distributed execution lock (Redis SETNX)