mirror of
https://github.com/scylladb/scylladb.git
synced 2026-06-06 15:03:06 +00:00
test: test_raft_recovery_stuck: ensure raft upgrade procedure failed
We have log browsing in test.py now, so we can fix this TODO easily. Closes scylladb/scylladb#18425
This commit is contained in:
committed by
Kamil Braun
parent
62a9ecff51
commit
3a100cd16c
@@ -69,8 +69,9 @@ async def test_recover_stuck_raft_recovery(request, manager: ManagerClient):
|
||||
await asyncio.gather(*(wait_for_upgrade_state('synchronize', cql, h, time.time() + 60) for h in hosts))
|
||||
logging.info(f"{hosts} entered synchronize")
|
||||
|
||||
# TODO ensure that srv1 failed upgrade - look at logs?
|
||||
# '[shard 0] raft_group0_upgrade - Raft upgrade failed: std::runtime_error (error injection before group 0 upgrade enters synchronize).'
|
||||
log_file1 = await manager.server_open_log(srv1.server_id)
|
||||
logging.info(f"Checking if Raft upgrade procedure failed on {srv1}")
|
||||
await log_file1.wait_for("error injection before group 0 upgrade enters synchronize")
|
||||
|
||||
logging.info(f"Setting recovery state on {hosts}")
|
||||
await asyncio.gather(*(enter_recovery_state(cql, h) for h in hosts))
|
||||
|
||||
Reference in New Issue
Block a user