@@ -26,6 +26,7 @@ import (
26
26
corev1 "k8s.io/api/core/v1"
27
27
apierrors "k8s.io/apimachinery/pkg/api/errors"
28
28
"k8s.io/apimachinery/pkg/types"
29
+ "k8s.io/klog/v2"
29
30
clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
30
31
"sigs.k8s.io/cluster-api/util"
31
32
"sigs.k8s.io/cluster-api/util/conditions"
@@ -71,7 +72,6 @@ func (r *HetznerBareMetalHostReconciler) Reconcile(ctx context.Context, req ctrl
71
72
72
73
// Fetch the Hetzner bare metal host instance.
73
74
bmHost := & infrav1.HetznerBareMetalHost {}
74
- // Use uncached APIReader to avoid cache issues.
75
75
err := r .Get (ctx , req .NamespacedName , bmHost )
76
76
if err != nil {
77
77
if apierrors .IsNotFound (err ) {
@@ -147,6 +147,8 @@ func (r *HetznerBareMetalHostReconciler) Reconcile(ctx context.Context, req ctrl
147
147
return reconcile.Result {}, fmt .Errorf ("failed to get HetznerCluster: %w" , err )
148
148
}
149
149
150
+ log = log .WithValues ("HetznerCluster" , klog .KObj (hetznerCluster ))
151
+
150
152
// Fetch the Cluster.
151
153
cluster , err := util .GetClusterFromMetadata (ctx , r .Client , hetznerCluster .ObjectMeta )
152
154
if err != nil {
@@ -239,6 +241,7 @@ func (r *HetznerBareMetalHostReconciler) reconcileSelectedStates(ctx context.Con
239
241
return reconcile.Result {}, fmt .Errorf ("Update() failed after setting ProvisioningState: %w" , err )
240
242
}
241
243
}
244
+
242
245
return ctrl.Result {RequeueAfter : 10 * time .Second }, nil
243
246
244
247
// Handle StateDeleting
0 commit comments