execution

type ErroDePasso struct {
	NodeID   string
	ExitCode int
	Mensagem string

	// Saida sao as ultimas linhas de stderr. Guardar so as ultimas, e nao tudo,
	// porque um processo verboso encheria a coluna de erro do banco — e a causa
	// quase sempre esta no fim.
	Saida []string
}

type Etapa struct {
	Nome    string         `json:"nome"`
	Estado  string         `json:"estado"`
	Ms      *int64         `json:"ms,omitempty"`
	Em      string         `json:"em"`
	Numeros map[string]any `json:"numeros,omitempty"`
}

type EtapaGravada = Etapa

type Historico interface {
	PassoJaTeveSucesso(ctx context.Context, workflowSlug, nodeID string, exceto uuid.UUID) (bool, error)
}

type Persistidor interface {
	IniciarTask(ctx context.Context, runID uuid.UUID, nodeID string, tentativa int) error
	TerminarTask(ctx context.Context, runID uuid.UUID, nodeID string, tentativa int,
		status run.Status, exit *int, erro string, log string) error

	// RegistrarEtapas grava o estado das etapas de um passo do SDK, enquanto
	// ele roda. E o que faz a tela avancar antes de o passo terminar.
	RegistrarEtapas(ctx context.Context, runID uuid.UUID, nodeID string, tentativa int,
		sdkVersao string, etapas json.RawMessage) error
}

type Reporter interface {
	Evento(execution.Event)
}

type Runner struct {
	Processo execution.Executor // atende `run:`; pode ser nil se so houver tasks Go
	Go       execution.Executor // atende `action:`; pode ser nil

	WorkDir string
	Env     map[string]string
	Report  Reporter

	// Timeout por no. Zero = sem limite.
	Timeout time.Duration

	// MaxTentativas por no. Zero ou 1 = tentativa unica.
	MaxTentativas int
	BackoffBase   time.Duration

	// Persist e RunID sao usados juntos: sem os dois, o estado por passo nao e
	// gravado e a DAG na UI aparece sem estado de execucao.
	Persist Persistidor
	RunID   uuid.UUID

	// Params sao os valores desta execucao. Entram no comando do passo por
	// template (ver execution.Renderizar) e no ambiente do passo, para que um
	// fetcher que use o SDK os enxergue sem receber nada por argumento.
	Params map[string]string

	// Trigger diz por que este Run existe: schedule, manual ou backfill.
	Trigger string

	// LogicalDate e o slot que este Run representa. Nulo em disparo manual.
	LogicalDate *time.Time

	// Historico decide se um passo esta rodando pela primeira vez. Nulo
	// significa que nao da para saber — e nesse caso o passo recebe
	// first=false, porque criar tabela sem certeza e pior que nao criar.
	Historico Historico

	// Vagas limita quantos PASSOS correm ao mesmo tempo — em Kubernetes, quantos
	// pods existem simultaneamente. Nulo = sem limite.
	//
	// Precisa ser compartilhado entre todos os Runners do processo, e por isso e
	// injetado em vez de criado aqui: o teto e do CLUSTER, nao de um workflow.
	// Sem ele, o limite de concorrencia do dispatcher contava RUNS — cinco runs
	// com tres passos paralelos cada davam quinze pods, nao cinco.
	Vagas chan struct{}

	// TentativaDoRun e a tentativa deste RUN, contada pelo dispatcher. Entra no
	// nome do pod para que um retry nao reencontre o pod da tentativa anterior.
	TentativaDoRun int

	// Pods executa passos como pod no Kubernetes. Quando presente, ele atende
	// todo passo que declara `image:` — e a mesma DAG roda em pod no cluster e
	// em processo na maquina, sem alterar o YAML.
	Pods execution.Executor
}