Skip to content

Commit

Permalink
fix: retry_v2变量免渲染问题处理 #7526 (#7529)
Browse files Browse the repository at this point in the history
* fix: retry_v2变量免渲染问题处理 #7526

* fix: retry_v2变量免渲染问题处理 #7526

* fix: retry_v2变量免渲染问题处理 #7526
  • Loading branch information
lTimej authored Sep 18, 2024
1 parent 9bd8e2a commit a6872ae
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion gcloud/taskflow3/domains/dispatchers/node.py
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,13 @@ def retry_v2(self, operator: str, **kwargs) -> dict:
return api_result
if "__executor_proxy" in api_result.data["inputs"] and kwargs["inputs"]:
kwargs["inputs"]["__executor_proxy"] = api_result.data["inputs"]["__executor_proxy"]["value"]

if kwargs["inputs"]:
render_keys = kwargs["inputs"].get("_escape_render_keys", [])
for k, v in api_result.data["inputs"].items():
if v.get("need_render") is False and k not in render_keys:
render_keys.append(k)
if render_keys:
kwargs["inputs"]["_escape_render_keys"] = render_keys
# 数据为空的情况传入 None, v2 engine api 不认为 {} 是空数据
return bamboo_engine_api.retry_node(runtime=runtime, node_id=self.node_id, data=kwargs["inputs"] or None)

Expand Down

0 comments on commit a6872ae

Please sign in to comment.