func()

in controllers/dsworker_controller.go [238:257]

• 18 lines of code
• 5 McCabe index (conditional complexity)

func (r *DSWorkerReconciler) ensureUpgraded(ctx context.Context, cluster *dsv1alpha1.DSWorker) (bool, error) {

	ms, err := r.podMemberSet(ctx, cluster)
	if err != nil {
		return false, err
	}

	for _, memset := range ms {
		if memset.Version != cluster.Spec.Version {
			pod := &corev1.Pod{}
			pod.SetName(memset.Name)
			pod.SetNamespace(memset.Namespace)
			if err := r.deleteMember(ctx, pod, cluster); err != nil {
				return false, err
			}
			return true, nil
		}
	}
	return false, nil
}