diff --git a/redis/asyncio/client.py b/redis/asyncio/client.py index 9d84e5a61e..ffd68c14d0 100644 --- a/redis/asyncio/client.py +++ b/redis/asyncio/client.py @@ -176,6 +176,7 @@ def __init__( auto_close_connection_pool: bool = True, redis_connect_func=None, credential_provider: Optional[CredentialProvider] = None, + protocol: Optional[int] = 2, ): """ Initialize a new Redis client. @@ -213,6 +214,7 @@ def __init__( "health_check_interval": health_check_interval, "client_name": client_name, "redis_connect_func": redis_connect_func, + "protocol": protocol, } # based on input, setup appropriate connection args if unix_socket_path is not None: