Skip to content

Commit e9f36e7

Browse files
committed
fixup
Signed-off-by: wenting <wentingwu@microsoft.com>
1 parent bc73bcf commit e9f36e7

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

operator/src/internal/controller/backup_controller.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,11 @@ func (r *BackupReconciler) SetBackupPhaseFailed(ctx context.Context, backup *dbp
231231
}
232232

233233
r.Recorder.Event(backup, "Warning", "BackupFailed", errMessage)
234-
return ctrl.Result{}, nil
234+
requeueAfter := time.Until(backup.Status.ExpiredAt.Time)
235+
if requeueAfter < 0 {
236+
requeueAfter = time.Minute
237+
}
238+
return ctrl.Result{RequeueAfter: requeueAfter}, nil
235239
}
236240

237241
func (r *BackupReconciler) SetBackupPhaseSkipped(ctx context.Context, backup *dbpreview.Backup, errMessage string, backupConfiguration *dbpreview.BackupConfiguration) (ctrl.Result, error) {
@@ -248,7 +252,11 @@ func (r *BackupReconciler) SetBackupPhaseSkipped(ctx context.Context, backup *db
248252
}
249253

250254
r.Recorder.Event(backup, "Warning", "BackupSkipped", errMessage)
251-
return ctrl.Result{}, nil
255+
requeueAfter := time.Until(backup.Status.ExpiredAt.Time)
256+
if requeueAfter < 0 {
257+
requeueAfter = time.Minute
258+
}
259+
return ctrl.Result{RequeueAfter: requeueAfter}, nil
252260
}
253261

254262
// SetupWithManager sets up the controller with the Manager.

0 commit comments

Comments
 (0)