Method cancelExecution

pkg/workflow/engine.go:919–949

cancelExecution 取消执行

(executionID string)

// cancelExecution 取消执行
func (e *Engine) cancelExecution(executionID string) {
	e.executionsMu.RLock()
	execution, exists := e.executions[executionID]
	e.executionsMu.RUnlock()

	if !exists {
		return
	}

	execution.mu.Lock()
	defer execution.mu.Unlock()

	if execution.Status != StatusRunning && execution.Status != StatusPaused {
		return
	}

	execution.cancelFunc()
	execution.Status = StatusCancelled
	execution.Context.Status = StatusCancelled
	execution.EndTime = time.Now()

	// 发布取消事件
	if e.eventBus != nil {
		_ = e.eventBus.Publish(execution.Context.Context, &WorkflowEvent{
			Type:        "workflow.cancelled",
			ExecutionID: executionID,
			NodeID:      "",
			Timestamp:   time.Now(),
		})
	}
}

// continueExecution 继续执行
func (e *Engine) continueExecution(execution *WorkflowExecution) {