diff --git a/pkg/rke2/workload_cluster_test.go b/pkg/rke2/workload_cluster_test.go index a42f165b..f8e01c76 100644 --- a/pkg/rke2/workload_cluster_test.go +++ b/pkg/rke2/workload_cluster_test.go @@ -374,8 +374,10 @@ var _ = Describe("Node metadata propagation", func() { })) result := &corev1.Node{} - Expect(testEnv.Get(ctx, client.ObjectKeyFromObject(node), result)).To(Succeed()) - Expect(result.GetAnnotations()).To(Equal(map[string]string{ + Eventually(func() map[string]string { + Expect(testEnv.Get(ctx, client.ObjectKeyFromObject(node), result)).To(Succeed()) + return result.GetAnnotations() + }).WithTimeout(2 * time.Minute).WithPolling(2 * time.Second).Should(Equal(map[string]string{ "test": "true", clusterv1.MachineAnnotation: machineDifferentNode.Name, }))