Method Execute

pkg/workflow/engine.go:189–218

Execute 执行工作流

(ctx context.Context, workflowID string, inputs map[string]any)

// Execute 执行工作流
func (e *Engine) Execute(ctx context.Context, workflowID string, inputs map[string]any) (*WorkflowResult, error) {
	// 加载工作流定义
	def, err := e.loadWorkflowDefinition(workflowID)
	if err != nil {
		return nil, fmt.Errorf("failed to load workflow definition: %w", err)
	}

	// 验证输入
	if err := e.validateInputs(def, inputs); err != nil {
		return nil, fmt.Errorf("invalid inputs: %w", err)
	}

	// 创建执行实例
	execution, err := e.createExecution(def, inputs)
	if err != nil {
		return nil, fmt.Errorf("failed to create execution: %w", err)
	}

	// 启动执行
	go e.executeWorkflow(execution)

	// 等待完成
	select {
	case <-execution.done:
		return execution.buildResult(), nil
	case <-ctx.Done():
		e.cancelExecution(execution.ID)
		return nil, ctx.Err()
	}
}

// ExecuteAsync 异步执行工作流
func (e *Engine) ExecuteAsync(ctx context.Context, workflowID string, inputs map[string]any) (string, error) {