Function New

pkg/workflow/workflow.go:68–88

New 创建新的 Workflow

(name string)

// New 创建新的 Workflow
func New(name string) *Workflow {
	return &Workflow{
		ID:                   uuid.New().String(),
		Name:                 name,
		Steps:                make([]Step, 0),
		MaxRetries:           3,
		Timeout:              30 * time.Minute,
		RetryDelay:           1 * time.Second,
		Stream:               false,
		StreamEvents:         false,
		StreamExecutorEvents: true,
		DebugMode:            false,
		StoreEvents:          false,
		StoreExecutorOutputs: true,
		SkipEvents:           make([]WorkflowEventType, 0),
		Metadata:             make(map[string]any),
		AddWorkflowHistory:   false,
		NumHistoryRuns:       3,
		CacheSession:         false,
	}
}

// ===== 流式 API =====