intake

type LocalAttemptBuilder func(context.Context) (dagrun.Attempt, error)

type LocalPreparation struct {
	Attempt dagrun.Attempt
	Proc    proc.ProcHandle
}

type LocalProcRepository interface {
	WithLock(ctx context.Context, groupName string, fn func() error) error
	Acquire(ctx context.Context, groupName string, meta proc.ProcMeta) (proc.ProcHandle, error)
}

type LocalRequest struct {
	ProcRepository LocalProcRepository
	DAG            *ir.DAG
	DAGRunID       string
	DefinitionID   string

	Root         ir.DAGRunRef
	Parent       ir.DAGRunRef
	TriggerType  ir.TriggerType
	TriggerActor string

	ScheduleTime string
	ProfileName  string

	LogBaseDir      string
	ArtifactBaseDir string

	BuildAttempt LocalAttemptBuilder
}

type OutputSource struct {
	RunID string
	// CapturedAt is an RFC 3339 timestamp, or empty when unknown.
	CapturedAt string
}

type QueueRequest struct {
	DAGRunRepository *persis.DAGRunRepository
	QueueStore       queue.QueueStore
	DAG              *ir.DAG
	DAGRunID         string

	QueueName string

	LogBaseDir      string
	ArtifactBaseDir string

	Root         ir.DAGRunRef
	Parent       ir.DAGRunRef
	TriggerType  ir.TriggerType
	TriggerActor string
	ParallelItem string
	ScheduleTime string
	ProfileName  string
	DefinitionID string
	NoReuse      bool

	AttemptOptions persis.DAGRunCreateAttemptOptions

	// ProceedOnStatusCloseErr preserves legacy CLI enqueue behavior: publish
	// the queue item after best-effort close so readers can see the queued status.
	ProceedOnStatusCloseErr bool

	Now func() time.Time
}

type QueuedRun struct {
	DAGRun      ir.DAGRunRef
	Attempt     dagrun.Attempt
	Status      ir.DAGRunStatus
	QueueName   string
	LogFile     string
	ArtifactDir string
	// StatusCloseErr is set only when ProceedOnStatusCloseErr allowed intake
	// to continue after the status attempt close failed.
	StatusCloseErr error
}

type RunStepSourceError struct {
	Message string
}

type RunStepSources map[string]*ir.DAGRunStatus

type SeedRequest struct {
	DAGRunRepository *persis.DAGRunRepository
	DAG              *ir.DAG
	DAGRunID         string
	Nodes            []runtime.NodeData
	// ReusedInputs records where the carried outputs of skipped nodes come from.
	ReusedInputs []ir.ReusedInput

	// SkipHandlers records that the run does not call the end-of-run handlers
	// of the DAG. See SelectionSkipsHandlers.
	SkipHandlers bool

	// Source is the run whose recorded outputs the skipped nodes carry. When
	// set, its work directory is copied into the new run and the carried
	// output variables are rewritten to point at the copy.
	Source *ir.DAGRunStatus

	Params       string
	TriggerType  ir.TriggerType
	TriggerActor string
	ProfileName  string
	DefinitionID string
	NoReuse      bool
	// Ephemeral stores the run apart from the history and marks it so that it
	// leaves no trace.
	Ephemeral bool

	LogBaseDir      string
	ArtifactBaseDir string
}