Method createExecution

pkg/workflow/engine.go:401–469

createExecution 创建执行实例

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

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

	ctx, cancel := context.WithCancel(context.Background())

	// 创建会话
	session, err := e.sessionManager.CreateSession(ctx, def.ID)
	if err != nil {
		cancel()
		return nil, fmt.Errorf("failed to create session: %w", err)
	}

	// 创建工作流上下文
	workflowCtx := &WorkflowContext{
		WorkflowID:  def.ID,
		ExecutionID: executionID,
		StartTime:   time.Now(),
		Status:      StatusPending,
		Variables:   make(map[string]any),
		Inputs:      inputs,
		Outputs:     make(map[string]any),
		Completed:   make(map[string]bool),
		Failed:      make(map[string]error),
		Metadata:    make(map[string]any),
		Context:     ctx,
		Session:     session,
	}

	execution := &WorkflowExecution{
		ID:             executionID,
		WorkflowID:     def.ID,
		Definition:     def,
		Status:         StatusPending,
		Context:        workflowCtx,
		CurrentNodes:   []string{},
		CompletedNodes: make(map[string]bool),
		FailedNodes:    make(map[string]error),
		NodeResults:    make(map[string]*NodeResult),
		StartTime:      time.Now(),
		LastActivity:   time.Now(),
		cancelFunc:     cancel,
		done:           make(chan struct{}),
		Errors:         make([]WorkflowError, 0),
		Warnings:       make([]string, 0),
	}

	// 注册执行
	e.executionsMu.Lock()
	e.executions[executionID] = execution
	e.executionsMu.Unlock()

	// 发布开始事件
	if e.eventBus != nil {
		_ = e.eventBus.Publish(ctx, &WorkflowEvent{
			Type:        "workflow.started",
			ExecutionID: executionID,
			NodeID:      "",
			Timestamp:   time.Now(),