diff options
Diffstat (limited to 'redis/asyncio/cluster.py')
| -rw-r--r-- | redis/asyncio/cluster.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index 1a33563..78dcd05 100644 --- a/redis/asyncio/cluster.py +++ b/redis/asyncio/cluster.py @@ -642,7 +642,7 @@ class RedisCluster(AbstractRedis, AbstractRedisCluster, AsyncRedisClusterCommand keys = [node.name for node in target_nodes] values = await asyncio.gather( *( - asyncio.ensure_future( + asyncio.create_task( self._execute_command(node, *args, **kwargs) ) for node in target_nodes @@ -841,7 +841,7 @@ class ClusterNode: async def disconnect(self) -> None: ret = await asyncio.gather( *( - asyncio.ensure_future(connection.disconnect()) + asyncio.create_task(connection.disconnect()) for connection in self._connections ), return_exceptions=True, @@ -979,13 +979,13 @@ class NodesManager: if remove_old: for name in list(old.keys()): if name not in new: - asyncio.ensure_future(old.pop(name).disconnect()) + asyncio.create_task(old.pop(name).disconnect()) for name, node in new.items(): if name in old: if old[name] is node: continue - asyncio.ensure_future(old[name].disconnect()) + asyncio.create_task(old[name].disconnect()) old[name] = node def _update_moved_slots(self) -> None: @@ -1202,7 +1202,7 @@ class NodesManager: self.default_node = None await asyncio.gather( *( - asyncio.ensure_future(node.disconnect()) + asyncio.create_task(node.disconnect()) for node in getattr(self, attr).values() ) ) @@ -1381,7 +1381,7 @@ class ClusterPipeline(AbstractRedis, AbstractRedisCluster, AsyncRedisClusterComm errors = await asyncio.gather( *( - asyncio.ensure_future(node[0].execute_pipeline(node[1])) + asyncio.create_task(node[0].execute_pipeline(node[1])) for node in nodes.values() ) ) |