Method executeWorkflowAsync

pkg/workflow/actor_engine.go:315–341

executeWorkflowAsync 异步执行工作流

(execution *WorkflowExecution, state *workflowState)

// executeWorkflowAsync 异步执行工作流
func (c *CoordinatorActor) executeWorkflowAsync(execution *WorkflowExecution, state *workflowState) {
	execution.mu.Lock()
	execution.Status = StatusRunning
	execution.mu.Unlock()

	// 查找开始节点
	startNodes := c.findStartNodes(execution.Definition)
	if len(startNodes) == 0 {
		state.errorCh <- errors.New("no start node found")
		return
	}

	// 执行节点
	if err := c.executeNodes(execution, state, startNodes); err != nil {
		state.errorCh <- err
		return
	}

	// 构建结果
	result := execution.buildResult()
	state.resultCh <- result

	// 清理
	c.mu.Lock()
	delete(c.runningWorkflows, execution.ID)
	c.mu.Unlock()
}

// executeNodes 执行节点列表
func (c *CoordinatorActor) executeNodes(execution *WorkflowExecution, state *workflowState, nodeIDs []string) error {