We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6751de2 commit fc116eaCopy full SHA for fc116ea
redis/asyncio/cluster.py
@@ -275,7 +275,7 @@ def __init__(
275
ssl_min_version: Optional[ssl.TLSVersion] = None,
276
ssl_ciphers: Optional[str] = None,
277
protocol: Optional[int] = 2,
278
- address_remap: Optional[Callable[[str, int], Tuple[str, int]]] = None,
+ address_remap: Optional[Callable[[Tuple[str, int]], Tuple[str, int]]] = None,
279
cache_enabled: bool = False,
280
client_cache: Optional[AbstractCache] = None,
281
cache_max_size: int = 100,
@@ -1152,7 +1152,7 @@ def __init__(
1152
startup_nodes: List["ClusterNode"],
1153
require_full_coverage: bool,
1154
connection_kwargs: Dict[str, Any],
1155
1156
) -> None:
1157
self.startup_nodes = {node.name: node for node in startup_nodes}
1158
self.require_full_coverage = require_full_coverage
redis/cluster.py
@@ -506,7 +506,7 @@ def __init__(
506
read_from_replicas: bool = False,
507
dynamic_startup_nodes: bool = True,
508
url: Optional[str] = None,
509
510
**kwargs,
511
):
512
"""
@@ -1347,7 +1347,7 @@ def __init__(
1347
lock=None,
1348
dynamic_startup_nodes=True,
1349
connection_pool_class=ConnectionPool,
1350
1351
1352
1353
self.nodes_cache = {}
0 commit comments