diff options
Diffstat (limited to 'tests/test_asyncio/test_cluster.py')
| -rw-r--r-- | tests/test_asyncio/test_cluster.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/tests/test_asyncio/test_cluster.py b/tests/test_asyncio/test_cluster.py index f4ea5cd..0d0ea33 100644 --- a/tests/test_asyncio/test_cluster.py +++ b/tests/test_asyncio/test_cluster.py @@ -2476,3 +2476,11 @@ class TestClusterPipeline: executed_on_replica = True break assert executed_on_replica + + async def test_can_run_concurrent_pipelines(self, r: RedisCluster) -> None: + """Test that the pipeline can be used concurrently.""" + await asyncio.gather( + *(self.test_redis_cluster_pipeline(r) for i in range(100)), + *(self.test_multi_key_operation_with_a_single_slot(r) for i in range(100)), + *(self.test_multi_key_operation_with_multi_slots(r) for i in range(100)), + ) |