feat: tendbHa定点回档增加slave延迟检查 TencentBlueKing#9096

zfrendo · Jan 17, 2025 · 3c41503 · 3c41503
1 parent 5d57a97
commit 3c41503
Showing 1 changed file with 13 additions and 12 deletions.
diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/mysql/mysql_rollback_data_flow.py b/dbm-ui/backend/flow/engine/bamboo/scene/mysql/mysql_rollback_data_flow.py
@@ -372,18 +372,6 @@ def rollback_to_cluster_flow(self):
                     act_component_code=ExecuteDBActuatorScriptComponent.code,
                     kwargs=asdict(exec_act_kwargs),
                 )
-                # 屏蔽监控，停止从库备份
-                rollback_pipeline.add_act(
-                    act_name=_("屏蔽监控 {}").format(rollback_storage.ip_port),
-                    act_component_code=MysqlCrondMonitorControlComponent.code,
-                    kwargs=asdict(
-                        CrondMonitorKwargs(
-                            bk_cloud_id=cluster_class.bk_cloud_id,
-                            exec_ips=[rollback_storage.machine.ip],
-                            port=rollback_storage.port,
-                        )
-                    ),
-                )
 
                 if rollback_storage.instance_role in (
                     InstanceRole.BACKEND_REPEATER.value,
@@ -402,6 +390,19 @@ def rollback_to_cluster_flow(self):
                         ),
                     )
 
+                # 屏蔽监控，停止从库备份
+                rollback_pipeline.add_act(
+                    act_name=_("屏蔽监控 {}").format(rollback_storage.ip_port),
+                    act_component_code=MysqlCrondMonitorControlComponent.code,
+                    kwargs=asdict(
+                        CrondMonitorKwargs(
+                            bk_cloud_id=cluster_class.bk_cloud_id,
+                            exec_ips=[rollback_storage.machine.ip],
+                            port=rollback_storage.port,
+                        )
+                    ),
+                )
+
                 if self.data["all_database_rollback"]:
                     rollback_pipeline.add_act(
                         act_name=_("从库stop slave {}").format(rollback_storage.ip_port),