Method ExecuteWithActors

pkg/workflow/actor_engine.go:100–138

ExecuteWithActors 使用 Actor 模型执行工作流

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

// ExecuteWithActors 使用 Actor 模型执行工作流
func (e *ActorEngine) ExecuteWithActors(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)
	}

	// 使用协调器执行
	resultCh := make(chan *WorkflowResult, 1)
	errCh := make(chan error, 1)

	e.coordinatorPID.Tell(&ExecuteWorkflowMsg{
		Execution: execution,
		ResultCh:  resultCh,
		ErrorCh:   errCh,
	})

	// 等待完成
	select {
	case result := <-resultCh:
		return result, nil
	case err := <-errCh:
		return nil, err
	case <-ctx.Done():
		_ = e.CancelExecution(execution.ID)
		return nil, ctx.Err()
	}
}

// SpawnAgent 在 Actor 系统中创建 Agent
func (e *ActorEngine) SpawnAgent(ctx context.Context, nodeID string, agentConfig *types.AgentConfig, deps *pkgagent.Dependencies) (*actor.PID, error) {