From 8c2b50b72e9b59dfd64c4255242ec6af17ea9e96 Mon Sep 17 00:00:00 2001 From: lonelyCZ <531187475@qq.com> Date: Thu, 7 Jul 2022 20:44:54 +0800 Subject: [PATCH] Fix check whether deployment propagated to member cluster Signed-off-by: lonelyCZ <531187475@qq.com> --- test/e2e/karmadactl_test.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/test/e2e/karmadactl_test.go b/test/e2e/karmadactl_test.go index 57f228cc9..26ad85bdc 100644 --- a/test/e2e/karmadactl_test.go +++ b/test/e2e/karmadactl_test.go @@ -337,7 +337,7 @@ var _ = framework.SerialDescribe("Karmadactl unjoin testing", ginkgo.Labels{Need }, }, policyv1alpha1.Placement{ ClusterAffinity: &policyv1alpha1.ClusterAffinity{ - ClusterNames: []string{deploymentName}, + ClusterNames: []string{clusterName}, }, }) karmadaConfig = karmadactl.NewKarmadaConfig(clientcmd.NewDefaultPathOptions()) @@ -380,8 +380,13 @@ var _ = framework.SerialDescribe("Karmadactl unjoin testing", ginkgo.Labels{Need }) ginkgo.By("Waiting for deployment have been propagated to the member cluster.", func() { klog.Infof("Waiting for deployment(%s/%s) synced on cluster(%s)", deploymentNamespace, deploymentName, clusterName) + + clusterConfig, err := clientcmd.BuildConfigFromFlags("", kubeConfigPath) + gomega.Expect(err).ShouldNot(gomega.HaveOccurred()) + clusterClient := kubernetes.NewForConfigOrDie(clusterConfig) + gomega.Eventually(func() bool { - _, err := kubeClient.AppsV1().Deployments(deploymentNamespace).Get(context.TODO(), deploymentName, metav1.GetOptions{}) + _, err := clusterClient.AppsV1().Deployments(deploymentNamespace).Get(context.TODO(), deploymentName, metav1.GetOptions{}) return err == nil }, pollTimeout, pollInterval).Should(gomega.Equal(true)) })