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

[migration] fix wrong pending_stop notification

This commit is contained in:
Kassian Sun 2023-04-20 16:53:41 +08:00 committed by Gitea
parent c691bbc607
commit e27a51f884
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
plugin/migration/pipeline.go
View File

@ -458,8 +458,7 @@ func (p *DispatcherProcessor) handlePendingStopSubTask(taskItem *task2.Task) err
// all subtask stopped or error or complete // all subtask stopped or error or complete
if len(tasks) == 0 { if len(tasks) == 0 {
taskItem.Status = task2.StatusStopped taskItem.Status = task2.StatusStopped
p.sendMajorTaskNotification(taskItem) p.saveTaskAndWriteLog(taskItem, "", nil, fmt.Sprintf("index migration task [%s] stopped", taskItem.ID))
p.saveTaskAndWriteLog(taskItem, "", nil, fmt.Sprintf("task [%s] stopped", taskItem.ID))
// clean disk queue if manually stopped // clean disk queue if manually stopped
p.cleanGatewayQueue(taskItem) p.cleanGatewayQueue(taskItem)
} }