workflow

type Dependency struct {
	Step  string `yaml:"step"`
	Label string `yaml:"label"`
}

type OnErrorSpec struct {
	Type string `yaml:"type"`
	When string `yaml:"when"`
}

type ParamSpec struct {
	Name        string   `yaml:"name"`
	Type        string   `yaml:"type"`
	Default     string   `yaml:"default"`
	Description string   `yaml:"description"`
	Enum        []string `yaml:"enum"`
	Pattern     string   `yaml:"pattern"`
}

type ResourceSpec struct {
	CPU    string `yaml:"cpu"`
	Memory string `yaml:"memory"`
	Limits struct {
		CPU    string `yaml:"cpu"`
		Memory string `yaml:"memory"`
	} `yaml:"limits"`
}

type Spec struct {
	Name        string       `yaml:"name"`
	Description string       `yaml:"description"`
	Schedule    string       `yaml:"schedule"`
	Type        string       `yaml:"type"`
	Tags        []string     `yaml:"tags"`
	Image       string       `yaml:"image"`
	Resources   ResourceSpec `yaml:"resources"`
	Params      []ParamSpec  `yaml:"params"`

	// Env and Secrets apply to every step; a step overrides them name by name.
	Env     map[string]string `yaml:"env"`
	Secrets map[string]string `yaml:"secrets"`
	// Concurrency is Kestra's `concurrency.limit`, under the name most
	// orchestrators use.
	Concurrency int        `yaml:"concurrency"`
	Steps       []StepSpec `yaml:"steps"`
}

type StepSpec struct {
	ID        string         `yaml:"id"`
	Run       string         `yaml:"run"`
	Action    string         `yaml:"action"`
	With      map[string]any `yaml:"with"`
	DependsOn []Dependency   `yaml:"depends_on"`

	// Image e Resources sobrescrevem os do workflow. Ausentes = herda.
	Image     string       `yaml:"image"`
	Host      string       `yaml:"host"`
	Resources ResourceSpec `yaml:"resources"`

	// Env are variables with a literal value in the file.
	//
	//	env:
	//	  BREVIS_LOG_LEVEL: info
	Env map[string]string `yaml:"env"`

	// Secrets are variables whose value is NOT in the file: the key is the
	// variable's name, the value is where to find it.
	//
	//	secrets:
	//	  GABRIEL_SESSION_COOKIE: gabriel-session/cookie
	Secrets map[string]string `yaml:"secrets"`

	// Runtime and Tools say what this step runs in, when the engine cannot
	// work it out from `run:` and `image:`.
	//
	//	runtime: python
	//	tools: [dbt]
	//
	// Both optional, and the engine INFERS both when they are absent -- which
	// is the normal case. Declaring one is for when the inference is wrong or
	// blind: a wrapper script, a bare binary path, an image whose name says
	// nothing.
	//
	// An id outside the vocabulary is refused at publish, naming what is
	// valid. The alternative is a chip that renders blank on a screen three
	// days later, with nothing to trace it to.
	Runtime string   `yaml:"runtime"`
	Tools   []string `yaml:"tools"`

	// Shell: a pointer, to tell "did not declare" from "declared false". Without
	// the pointer, every step without the key would become `shell: false` and
	// images that do have a shell -- most of them -- would start receiving an
	// argv, breaking any command with a pipe or a variable.
	Shell *bool `yaml:"shell"`

	// When is the trigger rule. Empty is `all_success`, which is what every
	// workflow written before this existed means.
	When string `yaml:"when"`

	// Marker is a step that does nothing and exists to be a point in the
	// graph -- a `start`, an `end`, a join. See dominio.Node.Marker.
	Marker bool `yaml:"marker"`

	// UnlessEmpty names a context key that decides whether this step runs.
	// A key, not an expression. See dominio.Node.UnlessEmpty.
	UnlessEmpty string `yaml:"unless_empty"`

	// ForEach names a context key holding a list. The step runs once per
	// element. See dominio.Node.ForEach.
	ForEach string `yaml:"for_each"`

	// Group draws this step inside a named box on the graph. Visual only.
	// See dominio.Node.Group.
	Group string `yaml:"group"`

	// Uses names another workflow whose steps take this one's place, expanded
	// at publish. See dominio.Node.Uses.
	Uses string `yaml:"uses"`

	// OnError announces this step's failures.
	//
	//	on_error:
	//	  type: SLACK
	//	  when: attempt     # optional; the default is give_up
	//
	// A pointer for the same reason Shell is: absent has to be different from
	// declared-and-empty, and a zero OnError would look like a step asking to
	// be announced to nowhere.
	OnError *OnErrorSpec `yaml:"on_error"`
}