runstate

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

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

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