Method runSubAgent

pkg/agent/workflow/parallel.go:112–152

runSubAgent 运行单个子 Agent

(
	ctx context.Context,
	agent Agent,
	branch string,
	index int,
	message string,
	results chan<- result,
	done <-chan struct{},
)

// runSubAgent 运行单个子 Agent
func (a *ParallelAgent) runSubAgent(
	ctx context.Context,
	agent Agent,
	branch string,
	index int,
	message string,
	results chan<- result,
	done <-chan struct{},
) error {
	agentReader := agent.Execute(ctx, message)
	for {
		event, err := agentReader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			select {
			case <-done:
				return nil
			case results <- result{err: err}:
			}
			return err
		}

		select {
		case <-done:
			return nil // 客户端取消
		case <-ctx.Done():
			select {
			case <-done:
			case results <- result{err: ctx.Err()}:
			}
			return ctx.Err()
		case results <- result{
			event: a.enrichEvent(event, branch, index),
			err:   nil,
		}:
		}
	}
	return nil
}

// enrichEvent 丰富事件信息，添加 branch 和元数据
func (a *ParallelAgent) enrichEvent(event *session.Event, branch string, index int) *session.Event {