mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: limit test_streaming_deadlock_removenode concurrency

Browse Source 
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 5235e3cf67)

Closes scylladb/scylladb#29778
This commit is contained in:
Aleksandra Martyniuk
2025-09-18 10:18:19 +02:00
committed by Piotr Dulikowski
parent 0433965946
commit 872320099d
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
test/topology_custom/test_streaming_deadlock.py
View File

@@ -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)