From 202401a30d7a4339cd8bf511189572645ff361e0 Mon Sep 17 00:00:00 2001 From: lukemakeit <2302063437@qq.com> Date: Thu, 12 Sep 2024 16:39:04 +0800 Subject: [PATCH] =?UTF-8?q?fix(redis):=20tendisplus=E5=8E=9F=E5=9C=B0?= =?UTF-8?q?=E5=8F=98=E6=9B=B4=E8=B5=8B=E5=80=BC=E9=94=99=E8=AF=AFbug=20#68?= =?UTF-8?q?95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../engine/bamboo/scene/redis/redis_slots_migrate_sub.py | 6 ++++-- 1 file changed, 4 insertions(+), 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 index eeeecead50..2f9a5f7b7a 100644 --- 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"])) + )