diff --git a/pkg/controllers/v1alpha1/databackup/status_handler.go b/pkg/controllers/v1alpha1/databackup/status_handler.go index 2354e2f3007..e19575f6bdb 100644 --- a/pkg/controllers/v1alpha1/databackup/status_handler.go +++ b/pkg/controllers/v1alpha1/databackup/status_handler.go @@ -59,7 +59,7 @@ func (o *OnceHandler) GetOperationStatus(ctx runtime.ReconcileRequestContext, ob // fail to get finishTime, use current time as default finishTime = time.Now() } - result.Duration = utils.CalculateDuration(object.GetCreationTimestamp().Time, finishTime) + result.Duration = utils.CalculateDuration(backupPod.CreationTimestamp.Time, finishTime) if kubeclient.IsSucceededPod(backupPod) { result.Phase = common.PhaseComplete diff --git a/pkg/controllers/v1alpha1/dataload/status_handler.go b/pkg/controllers/v1alpha1/dataload/status_handler.go index 815998a9ee3..beb92f90eec 100644 --- a/pkg/controllers/v1alpha1/dataload/status_handler.go +++ b/pkg/controllers/v1alpha1/dataload/status_handler.go @@ -89,7 +89,7 @@ func (r *OnceStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestCont } else { result.Phase = common.PhaseComplete } - result.Duration = utils.CalculateDuration(object.GetCreationTimestamp().Time, jobCondition.LastTransitionTime.Time) + result.Duration = utils.CalculateDuration(job.CreationTimestamp.Time, jobCondition.LastTransitionTime.Time) return } @@ -165,7 +165,7 @@ func (c *CronStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestCont } else { result.Phase = common.PhaseComplete } - result.Duration = utils.CalculateDuration(object.GetCreationTimestamp().Time, jobCondition.LastTransitionTime.Time) + result.Duration = utils.CalculateDuration(currentJob.CreationTimestamp.Time, jobCondition.LastTransitionTime.Time) return } } diff --git a/pkg/controllers/v1alpha1/datamigrate/status_handler.go b/pkg/controllers/v1alpha1/datamigrate/status_handler.go index 3c0333692ba..bdd16a84bf5 100644 --- a/pkg/controllers/v1alpha1/datamigrate/status_handler.go +++ b/pkg/controllers/v1alpha1/datamigrate/status_handler.go @@ -94,7 +94,7 @@ func (m *OnceStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestCont } else { result.Phase = common.PhaseComplete } - result.Duration = utils.CalculateDuration(object.GetCreationTimestamp().Time, jobCondition.LastTransitionTime.Time) + result.Duration = utils.CalculateDuration(job.CreationTimestamp.Time, jobCondition.LastTransitionTime.Time) return } } @@ -168,7 +168,7 @@ func (c *CronStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestCont } else { result.Phase = common.PhaseComplete } - result.Duration = utils.CalculateDuration(object.GetCreationTimestamp().Time, jobCondition.LastTransitionTime.Time) + result.Duration = utils.CalculateDuration(currentJob.CreationTimestamp.Time, jobCondition.LastTransitionTime.Time) return } } diff --git a/pkg/controllers/v1alpha1/dataprocess/status_handler.go b/pkg/controllers/v1alpha1/dataprocess/status_handler.go index b1747bc7710..f1518589b41 100644 --- a/pkg/controllers/v1alpha1/dataprocess/status_handler.go +++ b/pkg/controllers/v1alpha1/dataprocess/status_handler.go @@ -79,7 +79,7 @@ func (handler *OnceStatusHandler) GetOperationStatus(ctx runtime.ReconcileReques } else { result.Phase = common.PhaseComplete } - result.Duration = utils.CalculateDuration(object.GetCreationTimestamp().Time, jobCondition.LastTransitionTime.Time) + result.Duration = utils.CalculateDuration(job.CreationTimestamp.Time, jobCondition.LastTransitionTime.Time) return }