We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd1157d commit 934c689Copy full SHA for 934c689
redis/asyncio/connection.py
@@ -1128,6 +1128,7 @@ def __init__(
1128
health_check_interval: float = 0.0,
1129
client_name: str = None,
1130
retry: Optional[Retry] = None,
1131
+ redis_connect_func=None,
1132
):
1133
"""
1134
Initialize a new UnixDomainSocketConnection.
@@ -1153,6 +1154,7 @@ def __init__(
1153
1154
self.retry = Retry(NoBackoff(), 0)
1155
self.health_check_interval = health_check_interval
1156
self.next_health_check = -1
1157
+ self.redis_connect_func = redis_connect_func
1158
self.encoder = Encoder(encoding, encoding_errors, decode_responses)
1159
self._sock = None
1160
self._reader = None
0 commit comments