From d0706f460d61f57d09a62d481c65baccae3c98ed Mon Sep 17 00:00:00 2001 From: Kassian Sun Date: Wed, 17 May 2023 17:43:44 +0800 Subject: [PATCH] [migration] handle dump_hash/index_diff pending_stop --- plugin/migration/pipeline_task/pipeline_task.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/plugin/migration/pipeline_task/pipeline_task.go b/plugin/migration/pipeline_task/pipeline_task.go index 5809197f..b8566bb4 100644 --- a/plugin/migration/pipeline_task/pipeline_task.go +++ b/plugin/migration/pipeline_task/pipeline_task.go @@ -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"]) }