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)