Function sequentialExample

examples/workflow-agents/main.go:44–75

sequentialExample 顺序工作流示例

(ctx context.Context)

// sequentialExample 顺序工作流示例
func sequentialExample(ctx context.Context) {
	// 创建子 Agent
	agents := []workflow.Agent{
		NewMockAgent("DataCollector", "收集数据"),
		NewMockAgent("Analyzer", "分析数据"),
		NewMockAgent("Reporter", "生成报告"),
	}

	// 创建 SequentialAgent
	sequential, err := workflow.NewSequentialAgent(workflow.SequentialConfig{
		Name:      "DataPipeline",
		SubAgents: agents,
	})
	if err != nil {
		log.Fatal(err)
	}

	// 执行
	fmt.Println("开始顺序执行:")
	reader := sequential.Execute(ctx, "处理用户数据")
	for {
		event, err := reader.Recv()
		if err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			log.Printf("错误: %v", err)
			break
		}
		printEvent(event)
	}
}

// parallelExample 并行执行示例
func parallelExample(ctx context.Context) {