From 3a100cd16c76851356f3f5c7afbb4efd217e50fc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Patryk=20J=C4=99drzejczak?= Date: Thu, 25 Apr 2024 16:27:46 +0200 Subject: [PATCH] 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 --- test/topology_custom/test_raft_recovery_stuck.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/test/topology_custom/test_raft_recovery_stuck.py b/test/topology_custom/test_raft_recovery_stuck.py index 9f65f9bb8e..9d5f697a77 100644 --- a/test/topology_custom/test_raft_recovery_stuck.py +++ b/test/topology_custom/test_raft_recovery_stuck.py @@ -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))