mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-29 11:10:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
Botond Dénes
2025-04-17 03:01:17 -04:00
parent 19b4f10598
commit 22a28ca1db
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
test/cluster/test_read_repair.py
View File

@@ -196,10 +196,8 @@ async def test_incremental_read_repair(data_class: DataClass, manager: ManagerCl
"--cache-hit-rate-read-balancing", "0",
"--query-tombstone-page-limit", "10",
"--query-page-size-in-bytes", "1024"]
node1 = await manager.server_add(cmdline=cmdline)
node2 = await manager.server_add(cmdline=cmdline)
nodes = (node1, node2)
nodes = await manager.servers_add(2, cmdline=cmdline, auto_rack_dc="dc1")
node1, node2 = nodes
cql = manager.get_cql()
@@ -265,7 +263,7 @@ async def test_incremental_read_repair(data_class: DataClass, manager: ManagerCl
await manager.driver_connect()
cql, hosts = await manager.get_ready_cql(nodes)
logger.info("Check rows with CL=LOCAL_ONE before read-repair")
logger.info("Check rows before read-repair")
check_rows(cql, host1, node1_rows)
check_rows(cql, host2, node2_rows)
@@ -305,7 +303,7 @@ async def test_incremental_read_repair(data_class: DataClass, manager: ManagerCl
await manager.api.keyspace_flush(node.ip_addr, ks)
await manager.api.keyspace_compaction(node.ip_addr, ks)
logger.info("Check rows with CL=LOCAL_ONE after read-repair")
logger.info("Check rows after read-repair")
check_rows(cql, host1, all_rows)
check_rows(cql, host2, all_rows)