ok

app/services/scheduler_service.py

@@ -27,6 +27,13 @@ from app.services.supabase import SupabaseClient, get_supabase_client
 logger = get_logger(__name__)
 settings = get_settings()
 
+
+def _redact_url(url: str) -> str:
+    parsed = urlparse(url)
+    if parsed.password:
+        return url.replace(parsed.password, "****")
+    return url
+
 # ---------------------------------------------------------------------------
 # Redis lazy import helper
 # ---------------------------------------------------------------------------
@@ -554,10 +561,12 @@ class SchedulerService:
             else:
                 client = ra.Redis(**self._redis_conn_params(), decode_responses=True)
             await client.ping()
-            logger.info(
-                "Connected to Redis (url=%s)",
-                settings.redis_url or f"{settings.redis_host}:{settings.redis_port}",
+            log_url = (
+                _redact_url(settings.redis_url)
+                if settings.redis_url
+                else f"{settings.redis_host}:{settings.redis_port}"
             )
+            logger.info("Connected to Redis (url=%s)", log_url)
             return client
         except Exception as exc:
             logger.warning("Redis connection failed: %s — falling back to in-memory scheduler", exc)