diff --git a/CHANGES b/CHANGES index 8c6100d59d..8f2017218a 100644 --- a/CHANGES +++ b/CHANGES @@ -43,6 +43,7 @@ * Added a replacement for the default cluster node in the event of failure (#2463) * Fix for Unhandled exception related to self.host with unix socket (#2496) * Improve error output for master discovery + * Make `ClusterCommandsProtocol` an actual Protocol * 4.1.3 (Feb 8, 2022) * Fix flushdb and flushall (#1926) diff --git a/redis/typing.py b/redis/typing.py index 8504c7de0c..47a255652a 100644 --- a/redis/typing.py +++ b/redis/typing.py @@ -47,7 +47,7 @@ def execute_command(self, *args, **options): ... -class ClusterCommandsProtocol(CommandsProtocol): +class ClusterCommandsProtocol(CommandsProtocol, Protocol): encoder: Union["AsyncEncoder", "Encoder"] def execute_command(self, *args, **options) -> Union[Any, Awaitable]: