store

type ExecutionStateModel struct {
	ID         uint   `gorm:"primaryKey"`
	WorkflowID string `gorm:"size:128;index:idx_workflow_run,unique"`
	RunID      string `gorm:"size:128;index:idx_workflow_run,unique"`
	Status     string `gorm:"size:64"`
	StartedAt  time.Time
	UpdatedAt  time.Time
	Nodes      datatypes.JSON `gorm:"type:json"`
	CreatedAt  time.Time
	DeletedAt  gorm.DeletedAt `gorm:"index"`
}

type GormStateStore struct {
	// contains filtered or unexported fields
}

type InMemoryState struct {
	// contains filtered or unexported fields
}

type MemoryStateStore struct {
	// contains filtered or unexported fields
}

type PipelineState struct {
	CurrentStageIndex int
	// 如果Stage内部有多个Unit并行或串行执行的上下文，也需要记录当前Unit的进度
	CurrentUnitIndex int
	Status           string
	// 可以存储上一阶段的输出数据，用于从中间点恢复
	LastOutput any
}