Method Run

pkg/workflow/workflow_agent.go:191–210

Run 运行 WorkflowAgent

(ctx context.Context, input string)

// Run 运行 WorkflowAgent
func (wa *WorkflowAgent) Run(ctx context.Context, input string) (string, error) {
	wa.mu.RLock()
	workflow := wa.workflow
	wa.mu.RUnlock()

	if workflow == nil {
		return "", errors.New("no workflow attached to agent")
	}

	workflowInput := &WorkflowInput{
		Input: input,
	}

	result, err := wa.executeWorkflow(ctx, workflowInput)
	if err != nil {
		return "", err
	}

	return wa.formatOutput(result), nil
}

// RunStream 流式运行 WorkflowAgent
func (wa *WorkflowAgent) RunStream(ctx context.Context, input string) <-chan AgentStreamEvent {