diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_add_slave.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_add_slave.py index 091db259fb..1113ddec60 100644 --- a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_add_slave.py +++ b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_add_slave.py @@ -401,6 +401,7 @@ def add_slave_flow(self): sub_pipeline = SubBuilder(root_id=self.root_id, data=self.data) cluster_kwargs = deepcopy(act_kwargs) cluster_info = RedisClusterAddSlaveFlow.get_cluster_info(bk_biz_id, cluster_id) + cluster_kwargs.bk_cloud_id = cluster_info["bk_cloud_id"] # 海外多云区域 cluster_kwargs.cluster.update(cluster_info) cluster_kwargs.cluster["db_version"] = cluster_info["major_version"] cluster_kwargs.cluster["created_by"] = self.data["created_by"] diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_instance_shutdown.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_instance_shutdown.py index 6ccfb4bd59..c3f62cdafb 100644 --- a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_instance_shutdown.py +++ b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_instance_shutdown.py @@ -111,6 +111,7 @@ def start_instance_shutdown(self): for k, v in cluster_info.items(): cluster_kwargs.cluster[k] = v cluster_kwargs.cluster["created_by"] = self.data["created_by"] + cluster_kwargs.bk_cloud_id = cluster_info["bk_cloud_id"] # 海外多云区域 flow_data["shutdown_instances"] = cluster_instances redis_pipeline.add_act( act_name=_("初始化配置-{}".format(cluster_info["immute_domain"])), diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_auotfix.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_auotfix.py index ce3118fd7a..74104970d7 100644 --- a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_auotfix.py +++ b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_auotfix.py @@ -206,6 +206,7 @@ def start_redis_auotfix(self): cluster_kwargs = deepcopy(act_kwargs) cluster_info = self.get_cluster_info(self.data["bk_biz_id"], cluster_id) flow_data = self.data + cluster_kwargs.bk_cloud_id = cluster_info["bk_cloud_id"] # 海外多云区域 cluster_kwargs.cluster.update(cluster_info) cluster_kwargs.cluster["created_by"] = self.data["created_by"] flow_data["fix_info"] = cluster_fix diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_cmr.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_cmr.py index f07ac1bf73..688e8b1b57 100644 --- a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_cmr.py +++ b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_cmr.py @@ -229,6 +229,7 @@ def complete_machine_replace(self): sync_type = SyncType.SYNC_SMS.value flow_data = self.data + cluster_kwargs.bk_cloud_id = cluster_info["bk_cloud_id"] # 海外多云区域 cluster_kwargs.cluster.update(cluster_info) cluster_kwargs.cluster["created_by"] = self.data["created_by"] flow_data["sync_type"] = sync_type diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_mss.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_mss.py index 7a277131b0..4e0347d93b 100644 --- a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_mss.py +++ b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_cluster_scene_mss.py @@ -163,6 +163,7 @@ def redis_ms_switch(self): cluster_info = self.__get_cluster_info(self.data["bk_biz_id"], cluster_id) flow_data = self.data + cluster_kwargs.bk_cloud_id = cluster_info["bk_cloud_id"] # 海外多云区域 cluster_kwargs.cluster.update(cluster_info) cluster_kwargs.cluster["created_by"] = self.data["created_by"] cluster_kwargs.cluster["switch_option"] = ms_switch["online_switch_type"]