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

TencentBlueKing · Jan 26, 2025 · c48973e · c48973e
1 parent e40d0c4
commit c48973e
Showing 1 changed file with 5 additions and 9 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
@@ -54,6 +54,7 @@
 from backend.flow.utils.redis.redis_context_dataclass import ActKwargs, CommonContext, DnsKwargs
 from backend.flow.utils.redis.redis_db_meta import RedisDBMeta
 from backend.flow.utils.redis.redis_proxy_util import get_cluster_info_by_cluster_id
+from backend.flow.utils.redis.redis_util import version_ge
 
 logger = logging.getLogger("flow")
 
@@ -590,15 +591,10 @@ 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
-            ):
+            if act_kwargs.cluster["cluster_type"] in [
+                ClusterType.TendisRedisInstance.value,
+                ClusterType.TendisTwemproxyRedisInstance.value,
+            ] and version_ge(act_kwargs.cluster["db_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={})