pipeline

type Batch struct {
	Steps []Step `json:"steps,omitempty"`
}

type Checkpoint struct {
	Name string `json:"name,omitempty"`
	Step Step   `json:"step"`
}

type Conditional struct {
	Condition string `json:"condition,omitempty"`
	Then      Step   `json:"then"`
	Else      *Step  `json:"else,omitempty"`
}

type Executor struct {
	RunTool  func(context.Context, Step, []artifact.ArtifactRef) (*tool.ToolResult, error)
	RunSkill func(context.Context, Step, []artifact.ArtifactRef) (*tool.ToolResult, error)
	Cache    cache.Store
}

type FanIn struct {
	Strategy string `json:"strategy,omitempty"`
	Into     string `json:"into,omitempty"`
}

type FanOut struct {
	Collection string `json:"collection,omitempty"`
	Step       Step   `json:"step"`
}

type Input struct {
	Artifacts   []artifact.ArtifactRef
	Collections map[string][]artifact.ArtifactRef
	Items       []Result
}

type Result struct {
	Output     string
	Summary    string
	Artifacts  []artifact.ArtifactRef
	Structured any
	Preview    *tool.Preview
	Items      []Result
	Lineage    artifact.LineageGraph
}

type Retry struct {
	Attempts int  `json:"attempts,omitempty"`
	Step     Step `json:"step"`
}

type Step struct {
	Name        string                 `json:"name,omitempty"`
	Tool        string                 `json:"tool,omitempty"`
	Skill       string                 `json:"skill,omitempty"`
	Input       []artifact.ArtifactRef `json:"input,omitempty"`
	With        map[string]any         `json:"with,omitempty"`
	Batch       *Batch                 `json:"batch,omitempty"`
	FanOut      *FanOut                `json:"fan_out,omitempty"`
	FanIn       *FanIn                 `json:"fan_in,omitempty"`
	Conditional *Conditional           `json:"conditional,omitempty"`
	Retry       *Retry                 `json:"retry,omitempty"`
	Checkpoint  *Checkpoint            `json:"checkpoint,omitempty"`
}