Method buildResult

pkg/workflow/engine.go:957–992

buildResult 构建执行结果

()

// buildResult 构建执行结果
func (execution *WorkflowExecution) buildResult() *WorkflowResult {
	execution.mu.RLock()
	defer execution.mu.RUnlock()

	// 构建步骤跟踪
	var trace []WorkflowStep
	for _, result := range execution.NodeResults {
		step := WorkflowStep{
			NodeID:     result.NodeID,
			NodeName:   result.NodeName,
			NodeType:   result.NodeType,
			Status:     result.Status,
			StartTime:  result.StartTime,
			EndTime:    result.EndTime,
			Duration:   result.Duration,
			Inputs:     result.Inputs,
			Outputs:    result.Outputs,
			Error:      result.Error,
			RetryCount: result.RetryCount,
			Metadata:   result.Metadata,
		}
		trace = append(trace, step)
	}

	return &WorkflowResult{
		ExecutionID: execution.ID,
		WorkflowID:  execution.WorkflowID,
		Status:      execution.Status,
		StartTime:   execution.StartTime,
		EndTime:     execution.EndTime,
		Duration:    execution.EndTime.Sub(execution.StartTime),
		Outputs:     execution.Context.Outputs,
		Errors:      execution.Errors,
		Trace:       trace,
	}
}

// generateExecutionID 生成执行ID
func generateExecutionID() string {