Method executeWorkflow

pkg/workflow/workflow_agent.go:87–114

executeWorkflow 执行 workflow（非流式）

(ctx context.Context, input *WorkflowInput)

// executeWorkflow 执行 workflow（非流式）
func (wa *WorkflowAgent) executeWorkflow(ctx context.Context, input *WorkflowInput) (any, error) {
	var finalOutput any
	var finalError error

	reader := wa.workflow.Execute(ctx, input)
	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			finalError = err
			continue
		}

		if event.Type == EventWorkflowCompleted {
			if data, ok := event.Data.(map[string]any); ok {
				finalOutput = data["output"]
			}
		}
	}

	if finalError != nil {
		return nil, finalError
	}

	return wa.formatOutput(finalOutput), nil
}

// executeStreamingWorkflow 执行 workflow（流式）
func (wa *WorkflowAgent) executeStreamingWorkflow(ctx context.Context, input *WorkflowInput) (any, error) {