Skip to content

Commit 02ce069

Browse files
committed
Fixed test_client_kill test
1 parent c3f1adc commit 02ce069

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tests/test_asyncio/test_cluster.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1351,8 +1351,9 @@ async def test_client_info(self, r: RedisCluster) -> None:
13511351
assert "addr" in info
13521352

13531353
@skip_if_server_version_lt("2.6.9")
1354-
async def test_client_kill(self, r: RedisCluster, r2: RedisCluster) -> None:
1354+
async def test_client_kill(self, r: RedisCluster, create_redis: Callable[..., RedisCluster]) -> None:
13551355
node = r.get_primaries()[0]
1356+
r2 = await create_redis(cls=RedisCluster, flushdb=False)
13561357
await r.client_setname("redis-py-c1", target_nodes="all")
13571358
await r2.client_setname("redis-py-c2", target_nodes="all")
13581359
clients = [
@@ -1373,6 +1374,7 @@ async def test_client_kill(self, r: RedisCluster, r2: RedisCluster) -> None:
13731374
]
13741375
assert len(clients) == 1
13751376
assert clients[0].get("name") == "redis-py-c1"
1377+
await r2.close()
13761378

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

0 commit comments

Comments
 (0)