fix: wait for rook ceph migrator pod ready (#4571)

replicatedhq · May 31, 2023 · e39cb05 · e39cb05
1 parent 16a9e42
commit e39cb05
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/pkg/rook/flexvolume.go b/pkg/rook/flexvolume.go
@@ -252,10 +252,13 @@ func waitForFlexMigratorPod(ctx context.Context, clientset kubernetes.Interface)
 	if len(pods.Items) == 0 {
 		return nil, errors.New("no pods found for rook-ceph-migrator deployment")
 	}
-	pod := pods.Items[0]
+	for _, pod := range pods.Items {
+		if k8sutil.IsPodReady(pod) {
+			return &pod, nil
+		}
+	}
 
-	err = k8sutil.WaitForPodReady(ctx, clientset, pod.Namespace, pod.Name)
-	return &pod, errors.Wrap(err, "wait for rook-ceph-migrator pod")
+	return nil, errors.New("no ready pods found for rook-ceph-migrator deployment")
 }
 
 func generateFlexMigratorPatch(fs filesys.FileSystem, opts FlexvolumeToCSIOpts) error {