br: modify time complete of restore status (#5248)

pingcap · Aug 22, 2023 · cb6b246 · cb6b246
1 parent aeed0a4
commit cb6b246
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/cmd/backup-manager/app/restore/manager.go b/cmd/backup-manager/app/restore/manager.go
@@ -291,7 +291,6 @@ func (rm *Manager) performRestore(ctx context.Context, restore *v1alpha1.Restore
 			restoreType = v1alpha1.RestoreVolumeComplete
 		} else {
 			restoreType = v1alpha1.RestoreDataComplete
-			allFinished = true
 		}
 	default:
 		ts, err := util.GetCommitTsFromBRMetaData(ctx, restore.Spec.StorageProvider)
@@ -314,8 +313,10 @@ func (rm *Manager) performRestore(ctx context.Context, restore *v1alpha1.Restore
 	}
 
 	updateStatus := &controller.RestoreUpdateStatus{
-		TimeStarted: &metav1.Time{Time: started},
-		CommitTs:    commitTS,
+		CommitTs: commitTS,
+	}
+	if restore.Status.TimeStarted.Unix() <= 0 {
+		updateStatus.TimeStarted = &metav1.Time{Time: started}
 	}
 	if allFinished {
 		updateStatus.TimeCompleted = &metav1.Time{Time: time.Now()}

diff --git a/pkg/backup/restore/restore_manager.go b/pkg/backup/restore/restore_manager.go
@@ -513,10 +513,13 @@ func (rm *restoreManager) volumeSnapshotRestore(r *v1alpha1.Restore, tc *v1alpha
 		}
 
 		// restore TidbCluster completed
+		newStatus := &controller.RestoreUpdateStatus{
+			TimeCompleted: &metav1.Time{Time: time.Now()},
+		}
 		if err := rm.statusUpdater.Update(r, &v1alpha1.RestoreCondition{
 			Type:   v1alpha1.RestoreComplete,
 			Status: corev1.ConditionTrue,
-		}, nil); err != nil {
+		}, newStatus); err != nil {
 			return "UpdateRestoreCompleteFailed", err
 		}
 		return "", nil