Nits

Author: Yard1

redis/asyncio/cluster.py

@@ -1567,6 +1567,8 @@ async def _execute(
                     if name_exc:
                         name, exc = name_exc
                         command = " ".join(map(safe_str, cmd.args))
+                        # Note: this will only raise the first exception, but that is
+                        # consistent with RedisCluster.execute_command.
                         msg = (
                             f"Command # {cmd.position + 1} ({command}) of pipeline "
                             f"caused error on node {name}: "
@@ -1635,7 +1637,7 @@ def set_node_result(self, node_name: str, result: Union[Any, Exception]):
 
     def unwrap_result(
         self,
-    ) -> Optional[Union[Union[Any, Exception], Dict[str, Union[Any, Exception]]]]:
+    ) -> Optional[Union[Any, Exception, Dict[str, Union[Any, Exception]]]]:
         if len(self.result) == 0:
             return None
         if len(self.result) == 1: