Method ResumeExecution

pkg/workflow/engine.go:294–316

ResumeExecution 恢复执行

(executionID string)

// ResumeExecution 恢复执行
func (e *Engine) ResumeExecution(executionID string) error {
	e.executionsMu.RLock()
	execution, exists := e.executions[executionID]
	e.executionsMu.RUnlock()

	if !exists {
		return fmt.Errorf("execution not found: %s", executionID)
	}

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

	if execution.Status != StatusPaused {
		return fmt.Errorf("execution is not paused: %s", execution.Status)
	}

	execution.Status = StatusRunning

	// 恢复执行
	go e.continueExecution(execution)

	return nil
}

// ListExecutions 列出执行记录
func (e *Engine) ListExecutions(workflowID string, status WorkflowStatus, limit int) ([]*WorkflowExecution, error) {