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

[migration] don't send notification for repeating child tasks

This commit is contained in:
Kassian Sun 2023-06-05 17:45:08 +08:00
parent 5af5b2142e
commit 68b054783b
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugin/migration/cluster_comparison/cluster_comparison.go
View File

@ -412,6 +412,11 @@ func (p *processor) saveTaskAndWriteLog(taskItem *task.Task, taskResult *task.Ta
} }
func (p *processor) sendMajorTaskNotification(taskItem *task.Task) { 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{} config := migration_model.ClusterComparisonTaskConfig{}
err := migration_util.GetTaskConfig(taskItem, &config) err := migration_util.GetTaskConfig(taskItem, &config)
if err != nil { if err != nil {

5
plugin/migration/cluster_migration/cluster_migration.go
View File

@ -439,6 +439,11 @@ func (p *processor) saveTaskAndWriteLog(taskItem *task.Task, taskResult *task.Ta
} }
func (p *processor) sendMajorTaskNotification(taskItem *task.Task) { 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{} config := migration_model.ClusterMigrationTaskConfig{}
err := migration_util.GetTaskConfig(taskItem, &config) err := migration_util.GetTaskConfig(taskItem, &config)
if err != nil { if err != nil {