Skip to content

Commit aa37130

Browse files
committed
Fix requeue bug
1 parent bba1109 commit aa37130

File tree

5 files changed

+0
-9
lines changed

5 files changed

+0
-9
lines changed

internal/controller/federatedmanagedmetric_controller.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,6 @@ func (r *FederatedManagedMetricReconciler) scheduleNextReconciliation(metric *v1
8989

9090
elapsed := time.Since(metric.Status.LastReconcileTime.Time)
9191
return ctrl.Result{
92-
Requeue: true,
9392
RequeueAfter: metric.Spec.Interval.Duration - elapsed,
9493
}, nil
9594
}
@@ -241,7 +240,6 @@ func (r *FederatedManagedMetricReconciler) Reconcile(ctx context.Context, req ct
241240
l.Info(fmt.Sprintf("federated managed metric '%s' re-queued for execution in %v\n", metric.Spec.Name, requeueTime))
242241

243242
return ctrl.Result{
244-
Requeue: true,
245243
RequeueAfter: requeueTime,
246244
}, nil
247245
}

internal/controller/federatedmetric_controller.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,6 @@ func scheduleNextReconciliation(metric *v1alpha1.FederatedMetric) (ctrl.Result,
9090

9191
elapsed := time.Since(metric.Status.LastReconcileTime.Time)
9292
return ctrl.Result{
93-
Requeue: true,
9493
RequeueAfter: metric.Spec.Interval.Duration - elapsed,
9594
}, nil
9695
}
@@ -243,7 +242,6 @@ func (r *FederatedMetricReconciler) Reconcile(ctx context.Context, req ctrl.Requ
243242
l.Info(fmt.Sprintf("federated metric '%s' re-queued for execution in %v\n", metric.Spec.Name, requeueTime))
244243

245244
return ctrl.Result{
246-
Requeue: true,
247245
RequeueAfter: requeueTime,
248246
}, nil
249247
}

internal/controller/managedmetric_controller.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,6 @@ func (r *ManagedMetricReconciler) getRestConfig() *rest.Config {
6464
func (r *ManagedMetricReconciler) scheduleNextReconciliation(metric *v1alpha1.ManagedMetric) (ctrl.Result, error) {
6565
elapsed := time.Since(metric.Status.Observation.Timestamp.Time)
6666
return ctrl.Result{
67-
Requeue: true,
6867
RequeueAfter: metric.Spec.Interval.Duration - elapsed,
6968
}, nil
7069
}
@@ -262,7 +261,6 @@ func (r *ManagedMetricReconciler) Reconcile(ctx context.Context, req ctrl.Reques
262261
l.Info(fmt.Sprintf("managed metric '%s' re-queued for execution in %v\n", metric.Spec.Name, requeueTime))
263262

264263
return ctrl.Result{
265-
Requeue: true,
266264
RequeueAfter: requeueTime,
267265
}, nil
268266
}

internal/controller/metric_controller.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,6 @@ func (r *MetricReconciler) scheduleNextReconciliation(metric *v1alpha1.Metric) (
8585

8686
elapsed := time.Since(metric.Status.Observation.Timestamp.Time)
8787
return ctrl.Result{
88-
Requeue: true,
8988
RequeueAfter: metric.Spec.Interval.Duration - elapsed,
9089
}, nil
9190
}
@@ -267,7 +266,6 @@ func (r *MetricReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
267266
l.Info(fmt.Sprintf("metric '%s' re-queued for execution in %v\n", metric.Spec.Name, requeueTime))
268267

269268
return ctrl.Result{
270-
Requeue: true,
271269
RequeueAfter: requeueTime,
272270
}, nil
273271
}

internal/controller/metric_controller_test.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,6 @@ func (r *TestMetricReconciler) Reconcile(ctx context.Context, req ctrl.Request)
123123

124124
// Requeue
125125
return ctrl.Result{
126-
Requeue: true,
127126
RequeueAfter: metric.Spec.Interval.Duration,
128127
}, nil
129128
}

0 commit comments

Comments
 (0)