From 582006557eb3a3e4b95cf563d8f1e5e152914087 Mon Sep 17 00:00:00 2001 From: waylon <1158341873@qq.com> Date: Thu, 11 Jan 2024 14:44:42 +0800 Subject: [PATCH] fix: review fix #7289 --- gcloud/core/apis/drf/serilaziers/common_template.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/gcloud/core/apis/drf/serilaziers/common_template.py b/gcloud/core/apis/drf/serilaziers/common_template.py index e914099e48..921830b898 100644 --- a/gcloud/core/apis/drf/serilaziers/common_template.py +++ b/gcloud/core/apis/drf/serilaziers/common_template.py @@ -81,7 +81,7 @@ def _calculate_new_executor_proxies(self, old_pipeline_tree: dict, pipeline_tree old_executor_proxy = old_nodes.get(node_id, {}).get("executor_proxy") if not old_executor_proxy or executor_proxy != old_executor_proxy: new_executor_proxies.add(executor_proxy) - return set(new_executor_proxies) + return new_executor_proxies def _calculate_executor_proxies(self, pipeline_tree): new_executor_proxies = set() @@ -90,7 +90,7 @@ def _calculate_executor_proxies(self, pipeline_tree): if not executor_proxy: continue new_executor_proxies.add(executor_proxy) - return set(new_executor_proxies) + return new_executor_proxies def validate_pipeline_tree(self, value: str): pipeline_tree = json.loads(value)