feat: 添加子流程节点与重构工作流图构建

- 新增子流程节点(SubFlow)及SubFlowConfig配置结构
- 拆分BuildGraph与BuildGraphFromFlowContent,支持独立构建图与编译
- 移除ModelCallbackReq中多余字段,移除Intent节点注册
- 优化节点执行逻辑:调整OSS上传时机及变量引用
- 更新本地开发配置及依赖版本
This commit is contained in:
2026-06-24 09:30:55 +08:00
parent cfad80b359
commit bbd62c082d
+2 -2
View File
@@ -66,8 +66,8 @@ func SubFlowLambda(ctx context.Context, input any) (any, error) {
MaxConcurrency: subFlowConfig.MaxConcurrency, MaxConcurrency: subFlowConfig.MaxConcurrency,
}) })
skillName, from, userFrom := BuildParam(nodeExecInput) //skillName, from, userFrom := BuildParam(nodeExecInput)
fmt.Printf("skillName: %s, from: %s, userFrom: %s\n", skillName, from, userFrom) //fmt.Printf("skillName: %s, from: %s, userFrom: %s\n", skillName, from, userFrom)
// 6. 提取批量输入(从全局入参中获取) // 6. 提取批量输入(从全局入参中获取)
batchInputs := make([]*flowDto.FlowExecutionInput, 0) batchInputs := make([]*flowDto.FlowExecutionInput, 0)