Method validateInputs

pkg/workflow/engine.go:389–398

validateInputs 验证输入

(def *WorkflowDefinition, inputs map[string]any)

// validateInputs 验证输入
func (e *Engine) validateInputs(def *WorkflowDefinition, inputs map[string]any) error {
	for _, inputDef := range def.Inputs {
		if inputDef.Required {
			if _, exists := inputs[inputDef.Name]; !exists {
				return fmt.Errorf("required input missing: %s", inputDef.Name)
			}
		}
	}
	return nil
}

// createExecution 创建执行实例
func (e *Engine) createExecution(def *WorkflowDefinition, inputs map[string]any) (*WorkflowExecution, error) {