async_cluster: fix args for startup_nodes

Author: utkarshgupta137

redis/asyncio/cluster.py

@@ -302,7 +302,14 @@ def __init__(
         kwargs["response_callbacks"] = self.__class__.RESPONSE_CALLBACKS.copy()
         self.connection_kwargs = kwargs
 
-        if not startup_nodes:
+        if startup_nodes:
+            passed_nodes = []
+            for node in startup_nodes:
+                passed_nodes.append(
+                    ClusterNode(node.host, node.port, **self.connection_kwargs)
+                )
+            startup_nodes = passed_nodes
+        else:
             startup_nodes = []
         if host and port:
             startup_nodes.append(ClusterNode(host, port, **self.connection_kwargs))
@@ -1063,6 +1070,7 @@ async def initialize(self) -> None:
         fully_covered = False
         exception = None
         for startup_node in self.startup_nodes.values():
+            tmp_nodes_cache[startup_node.name] = startup_node
             try:
                 # Make sure cluster mode is enabled on this node
                 if not (await startup_node.execute_command("INFO")).get(

tests/test_asyncio/test_cluster.py

@@ -239,10 +239,18 @@ async def test_startup_nodes(self) -> None:
 
         await cluster.close()
 
-        startup_nodes = [ClusterNode("127.0.0.1", 16379)]
-        async with RedisCluster(startup_nodes=startup_nodes) as rc:
+        startup_node = ClusterNode("127.0.0.1", 16379)
+        async with RedisCluster(startup_nodes=[startup_node], client_name="test") as rc:
             assert await rc.set("A", 1)
             assert await rc.get("A") == b"1"
+            assert all(
+                [
+                    name == "test"
+                    for name in (
+                        await rc.client_getname(target_nodes=rc.ALL_NODES)
+                    ).values()
+                ]
+            )
 
     async def test_empty_startup_nodes(self) -> None:
         """