sts, err := appsv1Client.StatefulSets(d.cfg.Namespace.Name()).Get(context.TODO(), deploymentName, metav1.GetOptions{})
				if err != nil {
					return err
				}
				if sts.Spec.Replicas == nil || !statefulsetComplete(sts) {
					return fmt.Errorf("rollout is not yet done (updated replicas:%v)", sts.Status.UpdatedReplicas)
				}
			} else {