From 68b054783b07c01f1c7dd4c83a149332449c8b03 Mon Sep 17 00:00:00 2001
From: Kassian Sun <kassiansun@outlook.com>
Date: Mon, 5 Jun 2023 17:45:08 +0800
Subject: [PATCH] [migration] don't send notification for repeating child tasks

---
 plugin/migration/cluster_comparison/cluster_comparison.go | 5 +++++
 plugin/migration/cluster_migration/cluster_migration.go   | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/plugin/migration/cluster_comparison/cluster_comparison.go b/plugin/migration/cluster_comparison/cluster_comparison.go
index bfeb1669..2bdf3b43 100644
--- a/plugin/migration/cluster_comparison/cluster_comparison.go
+++ b/plugin/migration/cluster_comparison/cluster_comparison.go
@@ -412,6 +412,11 @@ func (p *processor) saveTaskAndWriteLog(taskItem *task.Task, taskResult *task.Ta
 }
 
 func (p *processor) sendMajorTaskNotification(taskItem *task.Task) {
+	// don't send notification for repeating child tasks
+	if len(taskItem.ParentId) > 0 {
+		return
+	}
+
 	config := migration_model.ClusterComparisonTaskConfig{}
 	err := migration_util.GetTaskConfig(taskItem, &config)
 	if err != nil {
diff --git a/plugin/migration/cluster_migration/cluster_migration.go b/plugin/migration/cluster_migration/cluster_migration.go
index 3dec3b8f..80b136c7 100644
--- a/plugin/migration/cluster_migration/cluster_migration.go
+++ b/plugin/migration/cluster_migration/cluster_migration.go
@@ -439,6 +439,11 @@ func (p *processor) saveTaskAndWriteLog(taskItem *task.Task, taskResult *task.Ta
 }
 
 func (p *processor) sendMajorTaskNotification(taskItem *task.Task) {
+	// don't send notification for repeating child tasks
+	if len(taskItem.ParentId) > 0 {
+		return
+	}
+
 	config := migration_model.ClusterMigrationTaskConfig{}
 	err := migration_util.GetTaskConfig(taskItem, &config)
 	if err != nil {