From 872320099d12ff401b92b7aeb2f4ee55a9eb5493 Mon Sep 17 00:00:00 2001 From: Aleksandra Martyniuk Date: Thu, 18 Sep 2025 10:18:19 +0200 Subject: [PATCH] test: limit test_streaming_deadlock_removenode concurrency test_streaming_deadlock_removenode starts 10240 inserts at once, overloading a node. Due to that test fails with timeout. Limit inserts concurrency. Fixes: #25945. Closes scylladb/scylladb#26102 (cherry picked from commit 5235e3cf67b5c49afaea5c33ad94042ed1c819f7) Closes scylladb/scylladb#29778 --- test/topology_custom/test_streaming_deadlock.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/test/topology_custom/test_streaming_deadlock.py b/test/topology_custom/test_streaming_deadlock.py index 738e7d9f79..b375bf0751 100644 --- a/test/topology_custom/test_streaming_deadlock.py +++ b/test/topology_custom/test_streaming_deadlock.py @@ -48,10 +48,11 @@ async def test_streaming_deadlock_removenode(request, manager: ManagerClient): await cql.run_async(f"CREATE MATERIALIZED VIEW {ks}.mv AS SELECT * FROM {ks}.test " "WHERE c IS NOT NULL and pk IS NOT NULL PRIMARY KEY (c, pk)") - keys = range(10240) + keys = range(1024) val = random_string(10240) stmt = cql.prepare(f"INSERT INTO {ks}.test (pk, c, v) VALUES (?, ?, '{val}')") - await asyncio.gather(*[cql.run_async(stmt, [k, k]) for k in keys]) + for _ in range(10): + await asyncio.gather(*[cql.run_async(stmt, [k, k]) for k in keys]) await manager.server_stop_gracefully(servers[0].server_id) await manager.remove_node(servers[1].server_id, servers[0].server_id)