Function nestedExample

examples/workflow-agents/main.go:166–211

nestedExample 嵌套工作流示例

(ctx context.Context)

// nestedExample 嵌套工作流示例
func nestedExample(ctx context.Context) {
	// 第一步：并行收集多个数据源
	dataCollectors := []workflow.Agent{
		NewMockAgent("Source1", "数据源1"),
		NewMockAgent("Source2", "数据源2"),
		NewMockAgent("Source3", "数据源3"),
	}
	parallelCollector, _ := workflow.NewParallelAgent(workflow.ParallelConfig{
		Name:      "ParallelCollector",
		SubAgents: dataCollectors,
	})

	// 第二步：分析
	analyzer := NewMockAgent("Analyzer", "数据分析")

	// 第三步：报告
	reporter := NewMockAgent("Reporter", "生成报告")

	// 组合成顺序工作流
	sequential, err := workflow.NewSequentialAgent(workflow.SequentialConfig{
		Name: "NestedWorkflow",
		SubAgents: []workflow.Agent{
			parallelCollector, // 并行收集
			analyzer,          // 分析
			reporter,          // 报告
		},
	})
	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)
	}
}

// ============================================================
// Mock Agent 实现（用于演示）