fix 1234

ymakedaq · Sep 24, 2024 · b602246 · b602246
1 parent 8a03f47
commit b602246
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/mysql/mysql_non_standby_slaves_upgrade.py b/dbm-ui/backend/flow/engine/bamboo/scene/mysql/mysql_non_standby_slaves_upgrade.py
@@ -184,13 +184,13 @@ def non_standby_slaves_upgrade_subflow(
         sync_data_sub_pipeline_list = build_data_repl_from_local_backup(
             root_id, parent_global_data, relation_cluster_ids, cluster, new_slave_ip, charset
         )
-        sub_pipeline.add_sub_pipeline(sub_flow=sync_data_sub_pipeline_list)
+        sub_pipeline.add_parallel_sub_pipeline(sync_data_sub_pipeline_list)
     elif backup_source == MySQLBackupSource.REMOTE:
         # 使用远程备份来做迁移
         sync_data_sub_pipeline_list = build_sync_data_sub_pipelines(
             root_id, parent_global_data, relation_cluster_ids, cluster, new_slave_ip
         )
-        sub_pipeline.add_sub_pipeline(sub_flow=sync_data_sub_pipeline_list)
+        sub_pipeline.add_parallel_sub_pipeline(sync_data_sub_pipeline_list)
 
     # 切换到新从节点
     if not add_slave_only: