runner

type IsolationMode string

type JobState = state.JobState

type Runner struct {
	WorkDir            string
	UseWorkDirOverride bool
	Stdout             io.Writer
	Stderr             io.Writer
	DryRun             bool
	JobID              string
	Retry              bool
	Verbose            bool
	Color              bool
	Executor           executor.Executor
	Runtime            executor.RuntimeContext
	Store              *state.Store
	ExecID             string
	// PlanID is the plan checksum short-form, injected as ORUN_PLAN_ID into
	// every step environment. Also used to build ORUN_JOB_RUN_ID.
	PlanID           string
	Concurrency      int
	FilterComponents []string
	FilterEnv        string
	Isolation        IsolationMode
	KeepWorkspaces   bool
	// SkipLocalDepsForJob disables the local dependency-completion check when
	// running a single --job in remote mode. The remote backend's claim API
	// already enforces dependency ordering.
	SkipLocalDepsForJob bool
	// Hooks wires external lifecycle callbacks (remote state, log upload, etc.).
	Hooks *RunnerHooks

	ComponentConcurrency int
	// contains filtered or unexported fields
}

type RunnerHooks struct {
	// AfterStepLog is called after each step completes with the step output.
	// It is called synchronously; implementations should be non-blocking or
	// fast to avoid delaying execution.
	AfterStepLog func(jobID, stepID, output string)
	// AfterJobTerminal is called when a job reaches a terminal state.
	AfterJobTerminal func(jobID string, success bool, errText string)
	// BeforeJob is called before a job starts. If it returns (true, nil) the job
	// is treated as already complete and execution is skipped. An error cancels
	// the run.
	BeforeJob func(jobID string) (skipExec bool, err error)
}

type State = state.ExecState