Fixed typing

Author: barshaul

redis/asyncio/cluster.py

@@ -11,6 +11,7 @@
     List,
     Mapping,
     Optional,
+    Tuple,
     Type,
     TypeVar,
     Union,
@@ -516,7 +517,7 @@ def set_response_callback(self, command: str, callback: ResponseCallbackT) -> No
 
     async def _determine_nodes(
         self, command: str, *args: Any, node_flag: Optional[str] = None
-    ) -> tuple[list["ClusterNode"], bool]:
+    ) -> Tuple[List["ClusterNode"], bool]:
         """Determine which nodes should be executed the command on
 
         Returns:

redis/cluster.py

@@ -4,7 +4,7 @@
 import threading
 import time
 from collections import OrderedDict
-from typing import Any, Callable, Dict, List, Optional, Tuple, TypeVar, Union
+from typing import Any, Callable, Dict, List, Optional, Tuple, Union
 
 from redis.backoff import default_backoff
 from redis.client import CaseInsensitiveDict, PubSub, Redis, parse_scan
@@ -38,10 +38,6 @@
     str_if_bytes,
 )
 
-TargetNodesT = TypeVar(
-    "TargetNodesT", str, "ClusterNode", List["ClusterNode"], Dict[Any, "ClusterNode"]
-)
-
 
 def get_node_name(host: str, port: Union[str, int]) -> str:
     return f"{host}:{port}"
@@ -839,7 +835,7 @@ def set_response_callback(self, command, callback):
         """Set a custom Response Callback"""
         self.cluster_response_callbacks[command] = callback
 
-    def _determine_nodes(self, *args, **kwargs) -> tuple[list["ClusterNode"], bool]:
+    def _determine_nodes(self, *args, **kwargs) -> Tuple[List["ClusterNode"], bool]:
         """Determine which nodes should be executed the command on
 
         Returns:

tests/test_asyncio/test_cluster.py

@@ -807,6 +807,8 @@ async def test_default_node_is_replaced_after_exception(self, r):
         nodes = await r.cluster_nodes()
         assert "myself" not in nodes.get(curr_default_node.name).get("flags")
         assert r.get_default_node() != curr_default_node
+        # Rollback to the old default node
+        r.replace_default_node(curr_default_node)
 
 
 class TestClusterRedisCommands:

tests/test_cluster.py

@@ -813,6 +813,8 @@ def raise_connection_error():
         nodes = r.cluster_nodes()
         assert "myself" not in nodes.get(curr_default_node.name).get("flags")
         assert r.get_default_node() != curr_default_node
+        # Rollback to the old default node
+        r.replace_default_node(curr_default_node)
 
 
 @pytest.mark.onlycluster