inference

type Bundle struct {
	ID    string
	Input []byte
}

type BundleRenderer interface {
	RenderBundles(template string, specJSON string, previousJSON string) ([]Bundle, error)
}

type Job interface {
	Name() string
	Build(ctx context.Context, spec SpecDocument, previous Results) ([]Task, error)
}

type Pipeline struct {
	Jobs     []Job
	Runner   Runner
	Store    Store
	Force    bool
	Limit    int
	Progress Progress
}

type Progress func(jobName, taskID string, cached bool)

type Results map[string]string

type Runner interface {
	Exec(ctx context.Context, task Task) ([]byte, error)
}

type SpecDocument struct {
	JSON string
}

type SpecLoader interface {
	LoadSpec(ctx context.Context, ref string) (SpecDocument, error)
}

type Store interface {
	Load(jobName string, taskID string) ([]byte, bool, error)
	Save(jobName string, taskID string, output []byte) error
	LoadAll(jobName string) (string, error)
}

type Task struct {
	JobName      string
	ID           string
	Input        []byte
	Prompt       string
	OutputSchema []byte
}