tests/e2e: use WaitLeader in corrupt test

Signed-off-by: Ivan Valdes <ivan@vald.es>
This commit is contained in:
Ivan Valdes 2024-02-07 16:23:06 -08:00
parent 8b2493256d
commit 07c4dcb90c
No known key found for this signature in database
GPG Key ID: 4037D37741ED0CC5

View File

@ -320,8 +320,10 @@ func TestCompactHashCheckDetectCorruptionInterrupt(t *testing.T) {
_, err = epc.Procs[slowCompactionNodeIndex].Logs().Expect("finished scheduled compaction")
require.NoError(t, err, "can't get log indicating finished scheduled compaction")
// Wait for compaction hash check
time.Sleep(checkTime * 5)
// Wait until the leader finished compaction hash check.
leaderIndex := epc.WaitLeader(t)
_, err = epc.Procs[leaderIndex].Logs().Expect("finished compaction hash check")
require.NoError(t, err, "can't get log indicating finished compaction hash check")
alarmResponse, err := cc.AlarmList()
require.NoError(t, err, "error on alarm list")