From 724e1e40c65c38d300a3032b1937c1de3bafff42 Mon Sep 17 00:00:00 2001 From: hanshuaikang <1758504262@qq.com> Date: Thu, 7 Sep 2023 15:40:16 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:=20=E4=BF=AE=E5=A4=8D=E7=8B=AC=E7=AB=8B?= =?UTF-8?q?=E5=AD=90=E6=B5=81=E7=A8=8B=E6=89=A7=E8=A1=8C=E5=8E=86=E5=8F=B2?= =?UTF-8?q?inputs=E6=A0=BC=E5=BC=8F=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- gcloud/taskflow3/domains/dispatchers/node.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/gcloud/taskflow3/domains/dispatchers/node.py b/gcloud/taskflow3/domains/dispatchers/node.py index c128716414..b53d4c99d9 100644 --- a/gcloud/taskflow3/domains/dispatchers/node.py +++ b/gcloud/taskflow3/domains/dispatchers/node.py @@ -750,10 +750,6 @@ def get_node_detail_v2( } for hist in hist_result.data: hist["ex_data"] = hist.get("outputs", {}).get("ex_data", "") - if node_info["type"] == "ServiceActivity" and node_code == "subprocess_plugin": - # 对于独立子流程节点要重新渲染输出 - raw_inputs = hist["inputs"]["subprocess"]["pipeline"]["constants"] - hist["inputs"] = {key[2:-1]: value.get("value") for key, value in raw_inputs.items()} detail["histories"] = hist_result.data detail["history_id"] = -1 # 如果用户传了 loop 参数,并且 loop 小于当前节点已循环次数,则从历史数据获取结果