opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-18 04:16:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(api): type _get_cluster_connection_health_params with TypedDict (#34999)

Browse Source
This commit is contained in:
YBoy 2026-04-13 02:52:12 +02:00 committed by GitHub
parent 6bacf7f953
commit 44ebfa3bb8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
api/extensions/ext_redis.py
View File

@ -141,6 +141,12 @@ class RedisHealthParamsDict(TypedDict):
health_check_interval: int | None health_check_interval: int | None
class RedisClusterHealthParamsDict(TypedDict):
retry: Retry
socket_timeout: float | None
socket_connect_timeout: float | None
class RedisBaseParamsDict(TypedDict): class RedisBaseParamsDict(TypedDict):
username: str | None username: str | None
password: str | None password: str | None
@ -211,7 +217,7 @@ def _get_connection_health_params() -> RedisHealthParamsDict:
) )
def _get_cluster_connection_health_params() -> dict[str, Any]: def _get_cluster_connection_health_params() -> RedisClusterHealthParamsDict:
"""Get retry and timeout parameters for Redis Cluster clients. """Get retry and timeout parameters for Redis Cluster clients.
RedisCluster does not support ``health_check_interval`` as a constructor RedisCluster does not support ``health_check_interval`` as a constructor
@ -219,8 +225,13 @@ def _get_cluster_connection_health_params() -> dict[str, Any]:
here. Only ``retry``, ``socket_timeout``, and ``socket_connect_timeout`` here. Only ``retry``, ``socket_timeout``, and ``socket_connect_timeout``
are passed through. are passed through.
""" """
params: dict[str, Any] = dict(_get_connection_health_params()) health_params = _get_connection_health_params()
return {k: v for k, v in params.items() if k != "health_check_interval"} result: RedisClusterHealthParamsDict = {
"retry": health_params["retry"],
"socket_timeout": health_params["socket_timeout"],
"socket_connect_timeout": health_params["socket_connect_timeout"],
}
return result
def _get_base_redis_params() -> RedisBaseParamsDict: def _get_base_redis_params() -> RedisBaseParamsDict: