fix(redis): tendisplus原地变更赋值错误bug #6895

TencentBlueKing · Sep 12, 2024 · 202401a · 202401a
1 parent 8d329a8
commit 202401a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_slots_migrate_sub.py b/dbm-ui/backend/flow/engine/bamboo/scene/redis/redis_slots_migrate_sub.py
@@ -467,7 +467,7 @@ def redis_rebalance_slots_4_expansion(root_id: str, flow_data: dict, act_kwargs:
     sub_pipeline.add_act(
         act_name=_("元数据更新"),
         act_component_code=RedisDBMetaComponent.code,
-        kwargs=asdict(cluster_kwargs),
+        kwargs=asdict(dbmeta_kwargs),
     )
     # ###元数据加入集群完成
 
@@ -505,4 +505,6 @@ def redis_rebalance_slots_4_expansion(root_id: str, flow_data: dict, act_kwargs:
         kwargs=asdict(record_kwargs),
     )
 
-    return sub_pipeline.build_sub_process(sub_name=_("迁移slots扩容{}".format(predixy_kwargs.cluster["immute_domain"])))
+    return sub_pipeline.build_sub_process(
+        sub_name=_("迁移slots扩容{}".format(predixy_kwargs.cluster["immute_domain"]))
+    )