Skip to content

Commit 354042a

Browse files
committed
Added wait for status to reflect authorityapi change
reduce time
1 parent 2eb2ed9 commit 354042a

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

e2e/machine_migration_vap_tests.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ var _ = Describe("[sig-cluster-lifecycle][OCPFeatureGate:MachineAPIMigration] MA
6060
testCAPIMachine = capiframework.GetMachine(cl, testMachineName, capiframework.CAPINamespace)
6161

6262
// Wait until VAP match conditions are met
63-
Eventually(komega.Object(testMAPIMachine), capiframework.WaitLong, capiframework.RetryMedium).Should(
63+
Eventually(komega.Object(testMAPIMachine), capiframework.WaitMedium, capiframework.RetryMedium).Should(
6464
WithTransform(func(m *mapiv1beta1.Machine) mapiv1beta1.MachineAuthority {
6565
return m.Status.AuthoritativeAPI
6666
}, Equal(mapiv1beta1.MachineAuthorityClusterAPI)),
@@ -283,6 +283,14 @@ func verifyVAPNotAppliedForMachineAPIAuthority() {
283283
// Create a test machine with MachineAPI authority
284284
testMachine := createMAPIMachineWithAuthority(ctx, cl, "vap-test-mapi-authority", mapiv1beta1.MachineAuthorityMachineAPI)
285285

286+
// Wait until status reflects the expected authority
287+
Eventually(komega.Object(testMachine), capiframework.WaitMedium, capiframework.RetryMedium).Should(
288+
WithTransform(func(m *mapiv1beta1.Machine) mapiv1beta1.MachineAuthority {
289+
return m.Status.AuthoritativeAPI
290+
}, Equal(mapiv1beta1.MachineAuthorityMachineAPI)),
291+
"Expected status.authoritativeAPI=MachineAPI before VAP bypass test",
292+
)
293+
286294
DeferCleanup(func() {
287295
By("Cleaning up test machine")
288296
mapiframework.DeleteMachines(ctx, cl, testMachine)

0 commit comments

Comments
 (0)