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
index 7337e187b4..96889327a1 100644
--- 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,20 +184,20 @@ 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_flows=sync_data_sub_pipeline_list)
+        sub_pipeline.add_sub_pipeline(sub_flow=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_flows=sync_data_sub_pipeline_list)
+        sub_pipeline.add_sub_pipeline(sub_flow=sync_data_sub_pipeline_list)
 
     # 切换到新从节点
     if not add_slave_only:
         switch_sub_pipeline_list = build_switch_sub_pipelines(
             root_id, parent_global_data, relation_cluster_ids, old_slave_ip, new_slave_ip
         )
-        sub_pipeline.add_parallel_sub_pipeline(sub_flows=switch_sub_pipeline_list)
+        sub_pipeline.add_parallel_sub_pipeline(sub_flow=switch_sub_pipeline_list)
 
     # 卸载旧从节点
     uninstall_svr_sub_pipeline = build_uninstall_sub_pipeline(