From bbd62c082dfc046195239238248cf8a2f6c58fa2 Mon Sep 17 00:00:00 2001 From: qhd <1766646056@qq.com> Date: Wed, 24 Jun 2026 09:30:55 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E5=AD=90=E6=B5=81?= =?UTF-8?q?=E7=A8=8B=E8=8A=82=E7=82=B9=E4=B8=8E=E9=87=8D=E6=9E=84=E5=B7=A5?= =?UTF-8?q?=E4=BD=9C=E6=B5=81=E5=9B=BE=E6=9E=84=E5=BB=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增子流程节点(SubFlow)及SubFlowConfig配置结构 - 拆分BuildGraph与BuildGraphFromFlowContent,支持独立构建图与编译 - 移除ModelCallbackReq中多余字段,移除Intent节点注册 - 优化节点执行逻辑:调整OSS上传时机及变量引用 - 更新本地开发配置及依赖版本 --- workflow/service/flow/lambda_node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/workflow/service/flow/lambda_node.go b/workflow/service/flow/lambda_node.go index ce9f21d..0a5e902 100644 --- a/workflow/service/flow/lambda_node.go +++ b/workflow/service/flow/lambda_node.go @@ -66,8 +66,8 @@ func SubFlowLambda(ctx context.Context, input any) (any, error) { MaxConcurrency: subFlowConfig.MaxConcurrency, }) - skillName, from, userFrom := BuildParam(nodeExecInput) - fmt.Printf("skillName: %s, from: %s, userFrom: %s\n", skillName, from, userFrom) + //skillName, from, userFrom := BuildParam(nodeExecInput) + //fmt.Printf("skillName: %s, from: %s, userFrom: %s\n", skillName, from, userFrom) // 6. 提取批量输入(从全局入参中获取) batchInputs := make([]*flowDto.FlowExecutionInput, 0)