summaryrefslogtreecommitdiff
path: root/redis/asyncio/connection.py
diff options
context:
space:
mode:
authorLazaros Toumanidis <lazToum@users.noreply.github.com>2022-03-14 13:47:27 +0200
committerGitHub <noreply@github.com>2022-03-14 13:47:27 +0200
commit934c6891c221157985743db76a2c9edb93ef45d6 (patch)
treee5cb7600f4beb092f0b878e6b94e87d97d2b698e /redis/asyncio/connection.py
parentdd1157daf0c3be18848d1ff96fdad2a10feb1c82 (diff)
downloadredis-py-934c6891c221157985743db76a2c9edb93ef45d6.tar.gz
redis_connect_func (#2046)
Diffstat (limited to 'redis/asyncio/connection.py')
-rw-r--r--redis/asyncio/connection.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/redis/asyncio/connection.py b/redis/asyncio/connection.py
index ae54d81..77fe95f 100644
--- a/redis/asyncio/connection.py
+++ b/redis/asyncio/connection.py
@@ -1128,6 +1128,7 @@ class UnixDomainSocketConnection(Connection): # lgtm [py/missing-call-to-init]
health_check_interval: float = 0.0,
client_name: str = None,
retry: Optional[Retry] = None,
+ redis_connect_func=None,
):
"""
Initialize a new UnixDomainSocketConnection.
@@ -1153,6 +1154,7 @@ class UnixDomainSocketConnection(Connection): # lgtm [py/missing-call-to-init]
self.retry = Retry(NoBackoff(), 0)
self.health_check_interval = health_check_interval
self.next_health_check = -1
+ self.redis_connect_func = redis_connect_func
self.encoder = Encoder(encoding, encoding_errors, decode_responses)
self._sock = None
self._reader = None