fix(redis): 扩容单据ssd版本报错 #9026

TencentBlueKing · Jan 10, 2025 · 5cf9504 · 5cf9504
1 parent 035f68f
commit 5cf9504
Showing 1 changed file with 7 additions and 10 deletions.
diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_backend_scale.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_backend_scale.py
@@ -590,16 +590,13 @@ def redis_backend_scale_flow(self):
                     )
 
             # > 4.0 版本需要重做一下slave，否则可能会丢数据
-            big_version = int(str.split(act_kwargs.cluster["db_version"], "-")[1])
-            if (
-                act_kwargs.cluster["cluster_type"]
-                in [
-                    ClusterType.TendisRedisInstance.value,
-                    ClusterType.TendisTwemproxyRedisInstance.value,
-                ]
-                and big_version >= 4
-            ):
-                sub_pipeline.add_parallel_acts(acts_list=self.redis_local_redo_dr(act_kwargs, sync_relations))
+            if act_kwargs.cluster["cluster_type"] in [
+                ClusterType.TendisRedisInstance.value,
+                ClusterType.TendisTwemproxyRedisInstance.value,
+            ]:
+                big_version = int(str.split(act_kwargs.cluster["db_version"], "-")[1])
+                if big_version >= 4:
+                    sub_pipeline.add_parallel_acts(acts_list=self.redis_local_redo_dr(act_kwargs, sync_relations))
 
             sub_pipeline.add_act(act_name=_("Redis-人工确认"), act_component_code=PauseComponent.code, kwargs={})