Skip to content

Commit eba9a09

Browse files
committed
Fixed test_client_kill test
1 parent 20608b0 commit eba9a09

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

tests/test_asyncio/test_cluster.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1347,8 +1347,11 @@ async def test_client_info(self, r: RedisCluster) -> None:
13471347
assert "addr" in info
13481348

13491349
@skip_if_server_version_lt("2.6.9")
1350-
async def test_client_kill(self, r: RedisCluster, r2: RedisCluster) -> None:
1350+
async def test_client_kill(
1351+
self, r: RedisCluster, create_redis: Callable[..., RedisCluster]
1352+
) -> None:
13511353
node = r.get_primaries()[0]
1354+
r2 = await create_redis(cls=RedisCluster, flushdb=False)
13521355
await r.client_setname("redis-py-c1", target_nodes="all")
13531356
await r2.client_setname("redis-py-c2", target_nodes="all")
13541357
clients = [
@@ -1369,6 +1372,7 @@ async def test_client_kill(self, r: RedisCluster, r2: RedisCluster) -> None:
13691372
]
13701373
assert len(clients) == 1
13711374
assert clients[0].get("name") == "redis-py-c1"
1375+
await r2.close()
13721376

13731377
@skip_if_server_version_lt("2.6.0")
13741378
async def test_cluster_bitop_not_empty_string(self, r: RedisCluster) -> None:

0 commit comments

Comments
 (0)