From 87d28c9cfc31ccce95ca7964b01136259faa0560 Mon Sep 17 00:00:00 2001
From: Kassian Sun <kassiansun@outlook.com>
Date: Tue, 4 Apr 2023 16:02:31 +0800
Subject: [PATCH] [migration] fix pending_stop checking logic

---
 plugin/migration/pipeline.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/plugin/migration/pipeline.go b/plugin/migration/pipeline.go
index 2b12b8b9..36ebc4bc 100644
--- a/plugin/migration/pipeline.go
+++ b/plugin/migration/pipeline.go
@@ -274,6 +274,13 @@ func (p *DispatcherProcessor) handlePendingStopMajorTask(taskItem *task2.Task) e
 		"query": util.MapStr{
 			"bool": util.MapStr{
 				"must": []util.MapStr{
+					{
+						"term": util.MapStr{
+							"parent_id": util.MapStr{
+								"value": taskItem.ID,
+							},
+						},
+					},
 					{
 						"term": util.MapStr{
 							"metadata.labels.business_id": "index_migration",