summaryrefslogtreecommitdiff
path: root/tests/test_asyncio/test_cluster.py
diff options
context:
space:
mode:
authorChayim <chayim@users.noreply.github.com>2023-03-29 12:01:45 +0300
committerGitHub <noreply@github.com>2023-03-29 12:01:45 +0300
commit5acbde355058ab7d9c2f95bcef3993ab4134e342 (patch)
treebc90887cf2fc77d870254b5618d32a1a701c9186 /tests/test_asyncio/test_cluster.py
parent6d886d7c7b405c0fe5d59ca192c87b438bf080f5 (diff)
downloadredis-py-5acbde355058ab7d9c2f95bcef3993ab4134e342.tar.gz
Fixing cancelled async futures (#2666)
Co-authored-by: James R T <jamestiotio@gmail.com> Co-authored-by: dvora-h <dvora.heller@redis.com>
Diffstat (limited to 'tests/test_asyncio/test_cluster.py')
-rw-r--r--tests/test_asyncio/test_cluster.py17
1 files changed, 0 insertions, 17 deletions
diff --git a/tests/test_asyncio/test_cluster.py b/tests/test_asyncio/test_cluster.py
index 0857c05..13e5e26 100644
--- a/tests/test_asyncio/test_cluster.py
+++ b/tests/test_asyncio/test_cluster.py
@@ -340,23 +340,6 @@ class TestRedisClusterObj:
rc = RedisCluster.from_url("rediss://localhost:16379")
assert rc.connection_kwargs["connection_class"] is SSLConnection
- async def test_asynckills(self, r) -> None:
-
- await r.set("foo", "foo")
- await r.set("bar", "bar")
-
- t = asyncio.create_task(r.get("foo"))
- await asyncio.sleep(1)
- t.cancel()
- try:
- await t
- except asyncio.CancelledError:
- pytest.fail("connection is left open with unread response")
-
- assert await r.get("bar") == b"bar"
- assert await r.ping()
- assert await r.get("foo") == b"foo"
-
async def test_max_connections(
self, create_redis: Callable[..., RedisCluster]
) -> None: