localrun

type Config struct {
	MaxParallel int
	TaskTimeout time.Duration
	RunTimeout  time.Duration
	Env         map[string]string // extra env vars injected into every task
	OnPrepared  func(store *run.Store, db *gorm.DB, jobModel *models.Job) error
	// EngineFactory overrides EVERY engine kind (docker, kubernetes, podman)
	// job.New dispatches steps through — a step's declared `engine:` picks
	// which of job.WithDockerEngineFactory/WithKubernetesEngineFactory/
	// WithPodmanEngineFactory job.New actually calls, and this field is wired
	// into all three identically, so a test fixture is never silently routed
	// to a real runtime just because a step used `engine: podman` or
	// `engine: kubernetes` instead of the (default) docker. nil (the default)
	// leaves job.New's own defaults in place, which drive real container
	// runtimes. Tests that need a hermetic run inject a fake engine here (see
	// internal/localrun/runner_test.go).
	EngineFactory func(context.Context) atom.Engine
}

type Display struct {
	Writer io.Writer
}

type RunResult struct {
	RunID  uuid.UUID
	JobID  uuid.UUID
	Alias  string
	Status string
	Error  string
	Tasks  []TaskResult
}

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

type TaskProgress struct {
	Name     string
	Status   string // pending, running, succeeded, failed, skipped
	Duration time.Duration
	Error    string
}

type TaskResult struct {
	TaskID uuid.UUID
	Name   string
	// Partition is set for each materialized instance of a fanned step (one
	// TaskResult per partition, Name rendered as "step[partition]"); empty for
	// unfanned steps.
	Partition        string
	Status           string
	Output           map[string]string
	SchemaViolations []pkgtask.SchemaViolation
	LogText          string
	LogTruncated     bool
	CacheHit         bool
	Error            string
}