runtimecodec

type ChapterEnvelope struct {
	ChapterType string
	Meta        ChapterMeta
	PayloadKind string
	Payload     json.RawMessage
}

type ChapterMeta struct {
	InitialPayloadDigest string                  `json:"initial_payload_digest,omitempty"`
	Version              int                     `json:"version"`
	Ordinal              int64                   `json:"ordinal"`
	TaskType             string                  `json:"task_type"`
	WorkerID             string                  `json:"worker_id"`
	CreatedAt            time.Time               `json:"created_at"`
	StartedAt            *time.Time              `json:"started_at,omitempty"`
	FinishedAt           *time.Time              `json:"finished_at,omitempty"`
	InputHash            string                  `json:"input_hash"`
	Metadata             json.RawMessage         `json:"metadata,omitempty"`
	Input                json.RawMessage         `json:"input,omitempty"`
	Attempt              int                     `json:"attempt,omitempty"`
	MaxAttempts          int                     `json:"max_attempts,omitempty"`
	NextAttemptAt        *time.Time              `json:"next_attempt_at,omitempty"`
	BackoffMillis        int64                   `json:"backoff_ms,omitempty"`
	Retryable            *bool                   `json:"retryable,omitempty"`
	InputRef             *jobdb.InputReference   `json:"input_ref,omitempty"`
	RunPolicy            *jobdb.RunPolicy        `json:"run_policy,omitempty"`
	Prerequisites        []jobdb.JobPrerequisite `json:"prereqs,omitempty"`
}

type SchedulerPayload struct {
	RunPolicy jobdb.RunPolicy
	TaskWait  *TaskWait
}

type TaskWait struct {
	InputStep  int64
	OutputStep int64
	Next       string
	InputHash  string
}