Traits: Filter GenerationChangedPredicate and log errors

Drop the use of retry.RetryOnConflict as it will block
the thread and therefor another reconciliation in the queue.

Author: fwiesel

internal/controller/traits_controller.go

@@ -19,17 +19,19 @@ package controller
 
 import (
 	"context"
+	"errors"
 	"slices"
 	"strings"
 	"time"
 
 	"k8s.io/apimachinery/pkg/api/meta"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
-	"k8s.io/client-go/util/retry"
 	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/builder"
 	k8sclient "sigs.k8s.io/controller-runtime/pkg/client"
 	logger "sigs.k8s.io/controller-runtime/pkg/log"
+	"sigs.k8s.io/controller-runtime/pkg/predicate"
 
 	"github.com/gophercloud/gophercloud/v2"
 	"github.com/gophercloud/gophercloud/v2/openstack/placement/v1/resourceproviders"
@@ -128,36 +130,37 @@ func (tc *TraitsController) Reconcile(ctx context.Context, req ctrl.Request) (ct
 }
 
 // UpdateStatusCondition updates the TraitsUpdated condition of the Hypervisor status and handles conflicts by retrying.
-func (tc *TraitsController) UpdateStatusCondition(ctx context.Context, orig *kvmv1.Hypervisor, err error, msg string) error {
-	return retry.RetryOnConflict(retry.DefaultRetry, func() error {
-		hv := &kvmv1.Hypervisor{}
-		if err := tc.Get(ctx, k8sclient.ObjectKeyFromObject(orig), hv); err != nil {
-			return err
-		}
-		// set status condition
-		var reason, message string
-		var status = metav1.ConditionTrue
-		reason = ConditionTraitsSuccess
+func (tc *TraitsController) UpdateStatusCondition(ctx context.Context, hv *kvmv1.Hypervisor, err error, msg string) error {
+	// set status condition
+	var (
+		reason  = ConditionTraitsSuccess
 		message = msg
+		status  = metav1.ConditionTrue
+	)
 
-		if err != nil {
-			status = metav1.ConditionFalse
-			reason = ConditionTraitsFailed
+	if err != nil {
+		status = metav1.ConditionFalse
+		reason = ConditionTraitsFailed
+		if msg != "" {
+			message = msg + ": " + err.Error()
+		} else {
 			message = err.Error()
-			if msg != "" {
-				message = msg + ": " + message
-			}
 		}
+	}
 
-		hv.Status.Traits = orig.Status.Traits
-		meta.SetStatusCondition(&hv.Status.Conditions, metav1.Condition{
-			Type:    ConditionTypeTraitsUpdated,
-			Status:  status,
-			Reason:  reason,
-			Message: message,
-		})
-		return tc.Status().Update(ctx, hv)
-	})
+	if meta.SetStatusCondition(&hv.Status.Conditions, metav1.Condition{
+		Type:    ConditionTypeTraitsUpdated,
+		Status:  status,
+		Reason:  reason,
+		Message: message,
+	}) {
+		if err != nil {
+			logger.FromContext(ctx).WithCallDepth(1).Error(err, msg)
+		}
+		return errors.Join(err, tc.Status().Update(ctx, hv))
+	}
+
+	return err
 }
 
 // SetupWithManager sets up the controller with the Manager.
@@ -173,6 +176,6 @@ func (tc *TraitsController) SetupWithManager(mgr ctrl.Manager) error {
 
 	return ctrl.NewControllerManagedBy(mgr).
 		Named(TraitsControllerName).
-		For(&kvmv1.Hypervisor{}).
+		For(&kvmv1.Hypervisor{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
 		Complete(tc)
 }