Method markExecutionFailed

pkg/workflow/engine.go:884–916

markExecutionFailed 标记执行失败

(execution *WorkflowExecution, err error)

// markExecutionFailed 标记执行失败
func (e *Engine) markExecutionFailed(execution *WorkflowExecution, err error) {
	execution.mu.Lock()
	defer execution.mu.Unlock()

	execution.Status = StatusFailed
	execution.Context.Status = StatusFailed
	execution.EndTime = time.Now()

	// 记录错误
	execution.Errors = append(execution.Errors, WorkflowError{
		NodeID:    "",
		NodeName:  "",
		Error:     err.Error(),
		Timestamp: time.Now(),
		Retryable: false,
	})

	// 更新指标
	e.metrics.FailedExecutions++

	// 发布失败事件
	if e.eventBus != nil {
		_ = e.eventBus.Publish(execution.Context.Context, &WorkflowEvent{
			Type:        "workflow.failed",
			ExecutionID: execution.ID,
			NodeID:      "",
			Timestamp:   time.Now(),
			Data: map[string]any{
				"error": err.Error(),
			},
		})
	}
}

// cancelExecution 取消执行
func (e *Engine) cancelExecution(executionID string) {