runstate

type Attempt interface {
	ID() string
	Open(ctx context.Context) error
	RecordStatus(ctx context.Context, status ir.DAGRunStatus) error
	RecordOutputs(ctx context.Context, outputs *ir.DAGRunOutputs) error
	ReadStatus(ctx context.Context) (*ir.DAGRunStatus, error)
	ReadOutputs(ctx context.Context) (*ir.DAGRunOutputs, error)
	RequestCancel(ctx context.Context) error
	CancelRequested(ctx context.Context) (bool, error)
	ReadStepMessages(ctx context.Context, stepName string) ([]ir.LLMMessage, error)
	WriteStepMessages(ctx context.Context, stepName string, messages []ir.LLMMessage) error
	MaterializeWorkDir(ctx context.Context) (string, error)
	SnapshotWorkDir(ctx context.Context, localDir string) error
	Close(ctx context.Context) error
}

type BeginAttemptRequest struct {
	DAG        *ir.DAG
	RunID      string
	AttemptID  string
	Retry      bool
	RootDAGRun ir.DAGRunRef
}

type Store interface {
	BeginAttempt(ctx context.Context, req BeginAttemptRequest) (Attempt, error)
	OpenAttempt(ctx context.Context, ref ir.DAGRunRef) (Attempt, error)
	OpenChildAttempt(ctx context.Context, root ir.DAGRunRef, childRunID string) (Attempt, error)
}