Function demoComplexWorkflow

examples/comprehensive/main.go:76–169

演示 2: 复杂 Workflow

(ctx context.Context)

// 演示 2: 复杂 Workflow
func demoComplexWorkflow(ctx context.Context) {
	// 创建一个数据处理 workflow
	wf := workflow.New("DataPipeline").
		WithStream().
		WithDebug()

	// 步骤 1: 数据收集
	wf.AddStep(workflow.NewFunctionStep("collect",
		func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
			fmt.Println("  📥 收集数据...")
			return &workflow.StepOutput{
				Content: map[string]any{
					"data":    []int{1, 2, 3, 4, 5},
					"source":  "api",
					"quality": "high",
				},
				Metadata: make(map[string]any),
			}, nil
		},
	))

	// 步骤 2: 条件分支 - 根据质量选择处理方式
	highQualityStep := workflow.NewFunctionStep("high_quality",
		func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
			fmt.Println("  ⚡ 使用高级算法处理...")
			data := input.PreviousStepContent.(map[string]any)
			return &workflow.StepOutput{
				Content:  fmt.Sprintf("高级处理: %v", data["data"]),
				Metadata: make(map[string]any),
			}, nil
		},
	)

	lowQualityStep := workflow.NewFunctionStep("low_quality",
		func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
			fmt.Println("  🔧 使用基础算法处理...")
			data := input.PreviousStepContent.(map[string]any)
			return &workflow.StepOutput{
				Content:  fmt.Sprintf("基础处理: %v", data["data"]),
				Metadata: make(map[string]any),
			}, nil
		},
	)

	wf.AddStep(workflow.NewConditionStep("quality_check",
		func(input *workflow.StepInput) bool {
			data := input.PreviousStepContent.(map[string]any)
			return data["quality"] == "high"
		},
		highQualityStep,
		lowQualityStep,
	))

	// 步骤 3: 并行任务
	task1 := workflow.NewFunctionStep("validate",
		func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
			fmt.Println("  ✓ 验证结果...")
			return &workflow.StepOutput{Content: "验证通过", Metadata: make(map[string]any)}, nil