diff --git a/test/e2e-multicluster-test/multicluster_test.go b/test/e2e-multicluster-test/multicluster_test.go index 85c09209a..c284aa6ef 100644 --- a/test/e2e-multicluster-test/multicluster_test.go +++ b/test/e2e-multicluster-test/multicluster_test.go @@ -115,8 +115,10 @@ var _ = Describe("Test multicluster scenario", func() { Expect(k8sClient.Delete(workerCtx, clusterRoleBinding)).Should(Succeed()) }() serviceAccount = &v1.ServiceAccount{} - Expect(k8sClient.Get(workerCtx, types.NamespacedName{Name: serviceAccountName, Namespace: "kube-system"}, serviceAccount)).Should(Succeed()) - Expect(len(serviceAccount.Secrets)).Should(Equal(1)) + Eventually(func(g Gomega) { + Expect(k8sClient.Get(workerCtx, types.NamespacedName{Name: serviceAccountName, Namespace: "kube-system"}, serviceAccount)).Should(Succeed()) + Expect(len(serviceAccount.Secrets)).Should(Equal(1)) + }, time.Second*30).Should(Succeed()) secret := &v1.Secret{} Expect(k8sClient.Get(workerCtx, types.NamespacedName{Name: serviceAccount.Secrets[0].Name, Namespace: "kube-system"}, secret)).Should(Succeed()) token, ok := secret.Data["token"]