floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

return last running task info

This commit is contained in:
liugq 2023-10-10 08:59:44 +08:00
parent 9f60c4685f
commit 12d4a8eef0
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/task_manager/cluster_comparison/cluster_comparison.go
View File

@ -56,9 +56,7 @@ func (p *processor) handleReadyMajorTask(taskItem *task.Task) error {
return nil return nil
} }
taskItem.RetryTimes++ taskItem.RetryTimes++
if taskItem.StartTimeInMillis == 0 { taskItem.StartTimeInMillis = time.Now().UnixMilli()
taskItem.StartTimeInMillis = time.Now().UnixMilli()
}
taskItem.Status = task.StatusRunning taskItem.Status = task.StatusRunning
taskItem.Metadata.Labels["total_diff_docs"] = 0 taskItem.Metadata.Labels["total_diff_docs"] = 0
taskItem.Metadata.Labels["only_in_source"] = 0 taskItem.Metadata.Labels["only_in_source"] = 0

6
plugin/task_manager/common_api.go
View File

@ -160,7 +160,11 @@ func (h *APIHandler) populateMajorTaskInfo(taskID string, sourceM util.MapStr) {
sourceM.Put("metadata.labels.source_total_docs", ts.SourceDocs) sourceM.Put("metadata.labels.source_total_docs", ts.SourceDocs)
} }
case "cluster_comparison": case "cluster_comparison":
ts, _, err := h.getComparisonMajorTaskInfo(taskID) targetTaskId := taskID
if repeatStatus.IsRepeat && repeatStatus.LastRunChildTaskID != "" {
targetTaskId = repeatStatus.LastRunChildTaskID
}
ts, _, err := h.getComparisonMajorTaskInfo(targetTaskId)
if err != nil { if err != nil {
log.Warnf("fetch progress info of task error: %v", err) log.Warnf("fetch progress info of task error: %v", err)
return return