File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -552,8 +552,8 @@ def __init__(
552
552
self .retry = Retry (NoBackoff (), 0 )
553
553
self .health_check_interval = health_check_interval
554
554
self .next_health_check = 0
555
- self .encoder = Encoder (encoding , encoding_errors , decode_responses )
556
555
self .redis_connect_func = redis_connect_func
556
+ self .encoder = Encoder (encoding , encoding_errors , decode_responses )
557
557
self ._sock = None
558
558
self ._socket_read_size = socket_read_size
559
559
self .set_parser (parser_class )
@@ -942,6 +942,7 @@ def __init__(
942
942
health_check_interval = 0 ,
943
943
client_name = None ,
944
944
retry = None ,
945
+ redis_connect_func = None ,
945
946
):
946
947
"""
947
948
Initialize a new UnixDomainSocketConnection.
@@ -966,6 +967,7 @@ def __init__(
966
967
self .retry = Retry (NoBackoff (), 0 )
967
968
self .health_check_interval = health_check_interval
968
969
self .next_health_check = 0
970
+ self .redis_connect_func = redis_connect_func
969
971
self .encoder = Encoder (encoding , encoding_errors , decode_responses )
970
972
self ._sock = None
971
973
self ._socket_read_size = socket_read_size
You can’t perform that action at this time.
0 commit comments