job

type DAGEdge struct {
	From            uuid.UUID `json:"from"`
	To              uuid.UUID `json:"to"`
	ContractDefined bool      `json:"contract_defined,omitempty"`
}

type DAGNode struct {
	ID           uuid.UUID       `json:"id"`
	AtomID       uuid.UUID       `json:"atom_id"`
	Type         string          `json:"type,omitempty"`
	Successors   []uuid.UUID     `json:"successors"`
	OutputSchema json.RawMessage `json:"output_schema,omitempty"`
	InputSchema  json.RawMessage `json:"input_schema,omitempty"`
}

type DAGResponse struct {
	JobID uuid.UUID `json:"job_id"`
	Nodes []DAGNode `json:"nodes"`
	Edges []DAGEdge `json:"edges"`
}

type JobResponse struct {
	*models.Job
	Trigger   *models.Trigger    `json:"trigger,omitempty"`
	LatestRun *runstorage.JobRun `json:"latest_run,omitempty"`
}

type MetadataRequest struct {
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
}

type PostRequest struct {
	Alias    string                 `json:"alias"`
	Metadata *MetadataRequest       `json:"metadata,omitempty"`
	Trigger  *trigger.CreateRequest `json:"trigger"`
	Tasks    []TaskRequest          `json:"tasks"`
}

type TaskRequest struct {
	Atom         *atom.CreateRequest `json:"atom"`
	DependsOn    []string            `json:"depends_on,omitempty"`
	NodeSelector map[string]string   `json:"node_selector,omitempty"`
}