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

[migration] handle dump_hash/index_diff pending_stop

This commit is contained in:
Kassian Sun 2023-05-17 17:43:44 +08:00
parent 8d27425fc0
commit d0706f460d
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugin/migration/pipeline_task/pipeline_task.go
View File

@ -195,6 +195,8 @@ func (p *processor) handlePendingStopPipelineTask(taskItem *task.Task) error {
switch taskItem.Metadata.Labels["pipeline_id"] {
case "es_scroll":
case "bulk_indexing":
case "dump_hash":
case "index_diff":
default:
return fmt.Errorf("task [%s] has unknown pipeline_id [%s]", taskItem.ID, taskItem.Metadata.Labels["pipeline_id"])
}