fix(proxy): validate coordination Redis mappings

Generated with AI

Co-Authored-By: Claude Code <noreply@anthropic.com>
This commit is contained in:
eugene-yao-zocdoc 2026-08-26 20:21:03 -04:00
parent bb043fe29a
commit 921c263876
2 changed files with 3 additions and 3 deletions

View file

@ -140,7 +140,7 @@ def _merge_over_saved(
def _validated_params(settings: Mapping[str, object]) -> CoordinationRedisParams:
"""Validate settings the way startup does: resolve env refs, then require a connection target."""
try:
params: Final = CoordinationRedisParams(**_resolve_env_refs(settings))
params: Final = CoordinationRedisParams.model_validate(_resolve_env_refs(settings))
except ValidationError as e:
invalid_fields: Final = sorted({str(error["loc"][0]) for error in e.errors() if error["loc"]})
raise HTTPException(

View file

@ -4906,7 +4906,7 @@ class ProxyConfig:
if not isinstance(raw_params, dict):
raise ValueError("general_settings.coordination_redis must be a mapping of Redis connection params")
coordination_params: Final = CoordinationRedisParams(**_resolve_coordination_redis_env_refs(raw_params))
coordination_params: Final = CoordinationRedisParams.model_validate(_resolve_coordination_redis_env_refs(raw_params))
if not coordination_params.has_connection_target():
raise ValueError(
"general_settings.coordination_redis needs a connection target: "
@ -9234,7 +9234,7 @@ class ProxyStartupEvent:
if persisted is None:
return None
coordination_params: Final = CoordinationRedisParams(**_resolve_coordination_redis_env_refs(persisted))
coordination_params: Final = CoordinationRedisParams.model_validate(_resolve_coordination_redis_env_refs(persisted))
if not coordination_params.has_connection_target():
verbose_proxy_logger.warning(
"coordination_redis saved in the database names no connection target; ignoring it."