Explicitly requeue during backoff ephemeral runner (#4152)
This commit is contained in:
parent
3b5693eecb
commit
9890c0592d
|
|
@ -201,12 +201,16 @@ func (r *EphemeralRunnerReconciler) Reconcile(ctx context.Context, req ctrl.Requ
|
||||||
backoffDuration := failedRunnerBackoff[len(ephemeralRunner.Status.Failures)]
|
backoffDuration := failedRunnerBackoff[len(ephemeralRunner.Status.Failures)]
|
||||||
nextReconciliation := lastFailure.Add(backoffDuration)
|
nextReconciliation := lastFailure.Add(backoffDuration)
|
||||||
if !lastFailure.IsZero() && now.Before(&metav1.Time{Time: nextReconciliation}) {
|
if !lastFailure.IsZero() && now.Before(&metav1.Time{Time: nextReconciliation}) {
|
||||||
|
requeueAfter := nextReconciliation.Sub(now.Time)
|
||||||
log.Info("Backing off the next reconciliation due to failure",
|
log.Info("Backing off the next reconciliation due to failure",
|
||||||
"lastFailure", lastFailure,
|
"lastFailure", lastFailure,
|
||||||
"nextReconciliation", nextReconciliation,
|
"nextReconciliation", nextReconciliation,
|
||||||
"requeueAfter", nextReconciliation.Sub(now.Time),
|
"requeueAfter", requeueAfter,
|
||||||
)
|
)
|
||||||
return ctrl.Result{RequeueAfter: now.Sub(nextReconciliation)}, nil
|
return ctrl.Result{
|
||||||
|
Requeue: true,
|
||||||
|
RequeueAfter: requeueAfter,
|
||||||
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
secret := new(corev1.Secret)
|
secret := new(corev1.Secret)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue