From d6c5a4f449ecf7be8d94d8d671d2abb0ff0f2bd1 Mon Sep 17 00:00:00 2001 From: ai-business-hql Date: Thu, 14 Aug 2025 06:57:05 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20get=5Fnode=5Finfos=E5=87=8F=E5=B0=91too?= =?UTF-8?q?lcall=E6=AC=A1=E6=95=B0,=E6=9C=AA=E7=9F=A5=E6=8A=A5=E9=94=99,?= =?UTF-8?q?=E5=9B=9E=E6=BB=9A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/service/workflow_rewrite_tools.py | 25 ++++++++++++----------- 1 file changed, 13 insertions(+), 12 deletions(-) diff --git a/backend/service/workflow_rewrite_tools.py b/backend/service/workflow_rewrite_tools.py index 2afda51..7881ff0 100644 --- a/backend/service/workflow_rewrite_tools.py +++ b/backend/service/workflow_rewrite_tools.py @@ -62,6 +62,7 @@ def get_current_workflow() -> str: return json.dumps({"error": "No workflow data found for this session"}) return json.dumps(workflow_data) +@function_tool async def get_node_info(node_class: str) -> str: """获取节点的详细信息，包括输入输出参数""" try: @@ -80,18 +81,18 @@ async def get_node_info(node_class: str) -> str: except Exception as e: return json.dumps({"error": f"Failed to get node info: {str(e)}"}) -@function_tool -async def get_node_infos(node_class_list: List[str]) -> str: - """获取多个节点的详细信息，包括输入输出参数""" - try: - node_infos = [] - for node_class in node_class_list: - node_info = await get_node_info(node_class) - if node_info: - node_infos.append(node_info) - return json.dumps(node_infos) - except Exception as e: - return json.dumps({"error": f"Failed to get node infos of {','.join(node_class_list)}: {str(e)}"}) +# @function_tool +# async def get_node_infos(node_class_list: List[str]) -> str: +# """获取多个节点的详细信息，包括输入输出参数""" +# try: +# node_infos = [] +# for node_class in node_class_list: +# node_info = await get_node_info(node_class) +# if node_info: +# node_infos.append(node_info) +# return json.dumps(node_infos) +# except Exception as e: +# return json.dumps({"error": f"Failed to get node infos of {','.join(node_class_list)}: {str(e)}"}) def save_checkpoint_before_modification(session_id: str, action_description: str) -> Optional[int]: """在修改工作流前保存checkpoint，返回checkpoint_id"""