diff --git a/plugin/migration/api.go b/plugin/migration/api.go index 5a25e018..5cbcb17b 100644 --- a/plugin/migration/api.go +++ b/plugin/migration/api.go @@ -266,9 +266,7 @@ func (h *APIHandler) getDataMigrationTaskOfIndex(w http.ResponseWriter, req *htt if ptask.StartTimeInMillis > 0 { if migration_util.IsPendingState(ptask.Status) { durationInMS = time.Now().UnixMilli() - ptask.StartTimeInMillis - continue - } - if ptask.CompletedTime != nil { + } else if ptask.CompletedTime != nil { subCompletedTime = ptask.CompletedTime.UnixMilli() durationInMS = subCompletedTime - ptask.StartTimeInMillis } @@ -576,7 +574,7 @@ func (h *APIHandler) getChildPipelineInfosFromGateway(pipelineTaskIDs map[string inst.ID = instID _, err = orm.Get(inst) if err != nil { - log.Error("failed to get instance info, err: %v", err) + log.Errorf("failed to get instance info, id: %s, err: %v", instID, err) continue } pipelines, err := inst.GetPipelinesByIDs(taskIDs) diff --git a/plugin/migration/comparison_api.go b/plugin/migration/comparison_api.go index 186a6b56..8cebb23c 100644 --- a/plugin/migration/comparison_api.go +++ b/plugin/migration/comparison_api.go @@ -287,9 +287,7 @@ func (h *APIHandler) getDataComparisonTaskOfIndex(w http.ResponseWriter, req *ht if subTask.StartTimeInMillis > 0 { if migration_util.IsPendingState(subTask.Status) { durationInMS = time.Now().UnixMilli() - subTask.StartTimeInMillis - continue - } - if subTask.CompletedTime != nil { + } else if subTask.CompletedTime != nil { subCompletedTime = subTask.CompletedTime.UnixMilli() durationInMS = subCompletedTime - subTask.StartTimeInMillis }