We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ded15f2 commit 4498cabCopy full SHA for 4498cab
redis/asyncio/cluster.py
@@ -269,7 +269,7 @@ def __init__(
269
ssl_min_version: Optional[ssl.TLSVersion] = None,
270
ssl_ciphers: Optional[str] = None,
271
protocol: Optional[int] = 2,
272
- address_remap: Optional[Callable[[str, int], Tuple[str, int]]] = None,
+ address_remap: Optional[Callable[[Tuple[str, int]], Tuple[str, int]]] = None,
273
) -> None:
274
if db:
275
raise RedisClusterException(
@@ -1098,7 +1098,7 @@ def __init__(
1098
startup_nodes: List["ClusterNode"],
1099
require_full_coverage: bool,
1100
connection_kwargs: Dict[str, Any],
1101
1102
1103
self.startup_nodes = {node.name: node for node in startup_nodes}
1104
self.require_full_coverage = require_full_coverage
redis/cluster.py
@@ -499,7 +499,7 @@ def __init__(
499
read_from_replicas: bool = False,
500
dynamic_startup_nodes: bool = True,
501
url: Optional[str] = None,
502
503
**kwargs,
504
):
505
"""
@@ -1310,7 +1310,7 @@ def __init__(
1310
lock=None,
1311
dynamic_startup_nodes=True,
1312
connection_pool_class=ConnectionPool,
1313
1314
1315
1316
self.nodes_cache = {}
0 commit comments