Function main

examples/workflow/main.go:15–146

()

)

func main() {
	fmt.Println("=== Aster Workflow 示例 ===")

	ctx := context.Background()

	// 创建 Workflow
	wf := workflow.New("DataProcessing").
		WithStream().
		WithDebug()

	// 步骤 1: 加载数据
	wf.AddStep(workflow.NewFunctionStep("load", func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
		fmt.Println("📥 Step 1: Loading data...")
		return &workflow.StepOutput{
			Content: map[string]any{
				"data":  []string{"item1", "item2", "item3"},
				"count": 3,
			},
			Metadata: make(map[string]any),
		}, nil
	}))

	// 步骤 2: 处理数据
	wf.AddStep(workflow.NewFunctionStep("process", func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
		fmt.Println("⚙️  Step 2: Processing data...")

		// 从前一步获取数据
		var dataMap map[string]any
		if input.PreviousStepContent != nil {
			dataMap, _ = input.PreviousStepContent.(map[string]any)
		}

		if dataMap != nil {
			if data, ok := dataMap["data"].([]string); ok {
				processed := make([]string, len(data))
				for i, item := range data {
					processed[i] = "processed_" + item
				}
				return &workflow.StepOutput{
					Content: map[string]any{
						"processed": processed,
						"count":     len(processed),
					},
					Metadata: make(map[string]any),
				}, nil
			}
		}

		return nil, errors.New("invalid input: expected map with 'data' field")
	}))

	// 步骤 3: 转换数据
	wf.AddStep(workflow.NewFunctionStep("transform", func(ctx context.Context, input *workflow.StepInput) (*workflow.StepOutput, error) {
		fmt.Println("🔄 Step 3: Transforming data...")

		result := "No data"
		if input.PreviousStepContent != nil {
			if dataMap, ok := input.PreviousStepContent.(map[string]any); ok {