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

[comparison] continue compare if doc count unmatch

This commit is contained in:
Kassian Sun 2023-06-13 17:09:21 +08:00 committed by Gitea
parent 57efd895b7
commit ea47e02a27
1 changed files with 0 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
plugin/task_manager/index_comparison/index_comparison.go
View File

@ -342,18 +342,6 @@ func (p *processor) handleRunningSubTask(taskItem *task.Task) error {
taskItem.Metadata.Labels["source_scrolled"] = sourceDocs taskItem.Metadata.Labels["source_scrolled"] = sourceDocs
taskItem.Metadata.Labels["target_scrolled"] = targetDocs taskItem.Metadata.Labels["target_scrolled"] = targetDocs
if sourceDocs != targetDocs {
now := time.Now()
taskItem.Metadata.Labels["total_diff_docs"] = sourceDocs
taskItem.CompletedTime = &now
taskItem.Status = task.StatusError
p.saveTaskAndWriteLog(taskItem, &task.TaskResult{
Success: false,
}, fmt.Sprintf("index comparison failed, source/target doc count unmatch: %d / %d", sourceDocs, targetDocs))
p.cleanGatewayQueue(taskItem)
p.scheduler.DecrInstanceJobs(instanceID)
return nil
}
if diffTask.Status == task.StatusInit { if diffTask.Status == task.StatusInit {
diffTask.Status = task.StatusReady diffTask.Status = task.StatusReady
p.saveTaskAndWriteLog(diffTask, &task.TaskResult{ p.saveTaskAndWriteLog(diffTask, &task.TaskResult{