diff --git a/redis/asyncio/cluster.py b/redis/asyncio/cluster.py index 1f34e03011..a109c0763a 100644 --- a/redis/asyncio/cluster.py +++ b/redis/asyncio/cluster.py @@ -1276,13 +1276,13 @@ def set_nodes( if remove_old: for name in list(old.keys()): if name not in new: - task = asyncio.create_task(old.pop(name).disconnect()) # noqa + asyncio.create_task(old.pop(name).disconnect()) for name, node in new.items(): if name in old: if old[name] is node: continue - task = asyncio.create_task(old[name].disconnect()) # noqa + asyncio.create_task(old[name].disconnect()) old[name] = node def update_moved_exception(self, exception):