model

Documentation

Index

• type ClassRef
• type Dag
• type DagRun
• type DagRuns
• type Dags
• type ImportError
• type ImportErrors
• type Logs
• type Tag
• type Task
• type TaskInstance
• type TaskInstances
• type Tasks

Types

type ClassRef

type ClassRef struct {
	ClassName  string `json:"class_name"`
	ModulePath string `json:"module_path"`
}

type Dag

type Dag struct {
	DagId            string           `json:"dag_id"`
	Description      string           `json:"description"`
	FileToken        string           `json:"file_token"`
	Fileloc          string           `json:"fileloc"`
	IsActive         bool             `json:"is_active"`
	IsPaused         bool             `json:"is_paused"`
	IsSubdag         bool             `json:"s_subdag"`
	Owners           []string         `json:"owners"`
	RootDagId        string           `json:"root_dag_id"`
	ScheduleInterval scheduleInterval `json:"schedule_interval"`
	Tags             []Tag            `json:"tags"`
	DefaultView      string           `json:"default_view"`
	NextDagrun       time.Time        `json:"next_dagrun"`
}

type DagRun

type DagRun struct {
	Conf            json.RawMessage `json:"conf"`
	DagId           string          `json:"dag_id"`
	DagRunId        string          `json:"dag_run_id"`
	ExternalTrigger bool            `json:"external_trigger"`
	State           string          `json:"state"`
	ExecutionDate   time.Time       `json:"execution_date"`
	LogicalDate     time.Time       `json:"logical_date"`
	StartDate       time.Time       `json:"start_date"`
	EndDate         time.Time       `json:"end_date"`
}

type DagRuns

type DagRuns struct {
	DagRun       []DagRun `json:"dag_runs"`
	TotalEntries int      `json:"total_entries"`
}

type Dags

type Dags struct {
	Dags         []Dag `json:"dags"`
	TotalEntries int   `json:"total_entries"`
}

type ImportError

type ImportError struct {
	ImportErrrorId int       `json:"import_error_id"`
	Timestamp      time.Time `json:"timestamp"`
	Filename       string    `json:"finlename"`
	Stacktrace     bool      `json:"stack_trace"`
}

type ImportErrors

type ImportErrors struct {
	ImportError  []ImportError `json:"import_errors"`
	TotalEntries int           `json:"total_entries"`
}

type Logs

type Logs struct {
	Content            json.RawMessage `json:"content"`
	ContinutationToken string          `json:"continuation_token"`
}

type Tag

type Tag struct {
	Tag string `json:"name"`
}

type Task

type Task struct {
	ClassRef                ClassRef        `json:"class_ref"`
	DependsOnPast           bool            `json:"depends_on_past"`
	DownstreamTaskIds       []string        `json:"downstream_task_ids"`
	EndDate                 time.Time       `json:"end_date"`
	ExecutionTimeout        string          `json:"execution_timeout"`
	ExtraLinks              json.RawMessage `json:"extra_links"`
	Owner                   string          `json:"owner"`
	Params                  json.RawMessage `json:"params"`
	Pool                    string          `json:"pool"`
	PoolSlots               float32         `json:"pool_slots"`
	PriorityWeight          float32         `json:"priority_weight"`
	Queue                   string          `json:"queue"`
	Retries                 float32         `json:"retries"`
	RetryDelay              json.RawMessage `json:"retry_delay"`
	RetryExponentialBackoff bool            `json:"retry_exponential_backoff"`
	StartDate               time.Time       `json:"start_date"`
	TaskId                  string          `json:"task_id"`
	TemplateFields          json.RawMessage `json:"template_fields"`
	TriggerRule             string          `json:"trigger_rule"`
	UiColor                 string          `json:"ui_color"`
	UiFgcolor               string          `json:"ui_fgcolor"`
	WaitForDownstream       bool            `json:"wait_for_downstream"`
	WeightRule              string          `json:"weight_rule"`
}

type TaskInstance

type TaskInstance struct {
	DagId          string          `json:"dag_id"`
	Duration       float64         `json:"duration"`
	EndDate        time.Time       `json:"end_date"`
	ExecutionDate  time.Time       `json:"execution_date"`
	ExecutorConfig json.RawMessage `json:"executor_config"`
	Hostname       string          `json:"hostname"`
	MaxTries       float64         `json:"max_tries"`
	Operator       string          `json:"operator"`
	Pid            float64         `json:"pid"`
	Pool           string          `json:"pool"`
	PoolSlots      float64         `json:"pool_slots"`
	PriorityWeight float64         `json:"priority_weight"`
	Queue          string          `json:"queue"`
	QueuedWhen     time.Time       `json:"queued_when"`
	Sla_miss       string          `json:"sla_miss"`
	StartDate      time.Time       `json:"start_date"`
	State          string          `json:"state"`
	TaskId         string          `json:"task_id"`
	TryNumber      float64         `json:"try_number"`
	Unixname       string          `json:"unixname"`
}

type TaskInstances

type TaskInstances struct {
	TaskInstance []TaskInstance `json:"task_instances"`
	TotalEntries int            `json:"total_entries"`
}

type Tasks

type Tasks struct {
	Task         []Task `json:"tasks"`
	TotalEntries int    `json:"total_entries"`
}