Skip to content

Commit 3d7350a

Browse files
committed
Revert "Save a reference to created async tasks, to avoid tasks potentially disappearing (redis#2816)"
This reverts commit 56b254e.
1 parent fabc23e commit 3d7350a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

redis/asyncio/cluster.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -1164,13 +1164,13 @@ def set_nodes(
11641164
if remove_old:
11651165
for name in list(old.keys()):
11661166
if name not in new:
1167-
task = asyncio.create_task(old.pop(name).disconnect()) # noqa
1167+
asyncio.create_task(old.pop(name).disconnect())
11681168

11691169
for name, node in new.items():
11701170
if name in old:
11711171
if old[name] is node:
11721172
continue
1173-
task = asyncio.create_task(old[name].disconnect()) # noqa
1173+
asyncio.create_task(old[name].disconnect())
11741174
old[name] = node
11751175

11761176
def _update_moved_slots(self) -> None:

0 commit comments

Comments
 (0)