fix

Author: iQQBot

components/node-labeler/cmd/run.go

@@ -244,7 +244,10 @@ func (r *PodReconciler) Reconcile(ctx context.Context, req reconcile.Request) (r
 	var node corev1.Node
 	err = r.Get(ctx, types.NamespacedName{Name: nodeName}, &node)
 	if err != nil {
-		return reconcile.Result{}, fmt.Errorf("obtaining node %s: %w", nodeName, err)
+		if !errors.IsNotFound(err) {
+			log.WithError(err).Error("obtaining node")
+		}
+		return reconcile.Result{}, client.IgnoreNotFound(err)
 	}
 
 	if isNodeTaintExists(taintKey, node) != healthy {
@@ -371,22 +374,32 @@ func (r *NodeReconciler) Reconcile(ctx context.Context, req reconcile.Request) (
 	if err != nil {
 		return reconcile.Result{}, fmt.Errorf("listing pods: %w", err)
 	}
+	err = updateNodeLabel(node.Name, r.Client)
+	if err != nil {
+		log.WithError(err).WithField("node", node.Name).Error("failed to initialize labels on node")
+	}
 	isWsdaemonTaintExists := isNodeTaintExists(wsDaemonTaintKey, node)
 	isRegistryFacadeTaintExists := isNodeTaintExists(registryFacadeTaintKey, node)
 	isWsDaemonReady, isRegistryFacadeReady := false, false
 	for _, pod := range podList.Items {
 		if strings.HasPrefix(pod.Name, wsDaemon) {
-			isWsDaemonReady = IsPodReady(pod)
+			isWsDaemonReady, err = checkPodHealth(pod)
+			if err != nil {
+				log.WithError(err).Error("checking pod health")
+			}
 		}
 		if strings.HasPrefix(pod.Name, registryFacade) {
-			isRegistryFacadeReady = IsPodReady(pod)
+			isRegistryFacadeReady, err = checkPodHealth(pod)
+			if err != nil {
+				log.WithError(err).Error("checking pod health")
+			}
 		}
 	}
 	if isWsDaemonReady == isWsdaemonTaintExists {
-		updateNodeTaint(wsDaemonTaintKey, isWsDaemonReady, node.Name, r)
+		updateNodeTaint(wsDaemonTaintKey, !isWsDaemonReady, node.Name, r)
 	}
 	if isRegistryFacadeReady == isRegistryFacadeTaintExists {
-		updateNodeTaint(registryFacadeTaintKey, isRegistryFacadeReady, node.Name, r)
+		updateNodeTaint(registryFacadeTaintKey, !isRegistryFacadeReady, node.Name, r)
 	}
 	return reconcile.Result{}, nil
 }