Skip to content

Commit d0cdf39

Browse files
committed
Fix returning non-empty reconcile result and error
1 parent 5d62dd5 commit d0cdf39

File tree

2 files changed

+21
-5
lines changed

2 files changed

+21
-5
lines changed

controllers/openstackcluster_controller.go

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -121,11 +121,20 @@ func (r *OpenStackClusterReconciler) Reconcile(ctx context.Context, req ctrl.Req
121121

122122
// Handle deleted clusters
123123
if !openStackCluster.DeletionTimestamp.IsZero() {
124-
return r.reconcileDelete(ctx, scope, cluster, openStackCluster)
124+
result, err := r.reconcileDelete(ctx, scope, cluster, openStackCluster)
125+
if err != nil {
126+
return reconcile.Result{}, err
127+
}
128+
return result, nil
125129
}
126130

127131
// Handle non-deleted clusters
128-
return reconcileNormal(scope, cluster, openStackCluster)
132+
result, err := reconcileNormal(scope, cluster, openStackCluster)
133+
if err != nil {
134+
return reconcile.Result{}, err
135+
}
136+
137+
return result, nil
129138
}
130139

131140
func (r *OpenStackClusterReconciler) reconcileDelete(ctx context.Context, scope scope.Scope, cluster *clusterv1.Cluster, openStackCluster *infrav1.OpenStackCluster) (ctrl.Result, error) {
@@ -297,8 +306,11 @@ func reconcileNormal(scope scope.Scope, cluster *clusterv1.Cluster, openStackClu
297306
}
298307

299308
result, err := reconcileBastion(scope, cluster, openStackCluster)
300-
if err != nil || !reflect.DeepEqual(result, reconcile.Result{}) {
301-
return result, err
309+
if err != nil {
310+
return reconcile.Result{}, err
311+
}
312+
if !result.IsZero() {
313+
return result, nil
302314
}
303315

304316
availabilityZones, err := computeService.GetAvailabilityZones()

controllers/openstackmachine_controller.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,11 @@ func (r *OpenStackMachineReconciler) Reconcile(ctx context.Context, req ctrl.Req
158158
}
159159

160160
// Handle non-deleted clusters
161-
return r.reconcileNormal(ctx, scope, cluster, infraCluster, machine, openStackMachine)
161+
result, err := r.reconcileNormal(ctx, scope, cluster, infraCluster, machine, openStackMachine)
162+
if err != nil {
163+
return reconcile.Result{}, err
164+
}
165+
return result, nil
162166
}
163167

164168
func patchMachine(ctx context.Context, patchHelper *patch.Helper, openStackMachine *infrav1.OpenStackMachine, machine *clusterv1.Machine, options ...patch.Option) error {

0 commit comments

Comments
 (0)