`airflow.utils.state`¶

模組內容¶

類別¶

`JobState (任務狀態)`	Job 可能處於的所有可能狀態。
`TaskInstanceState (任務實例狀態)`	Task Instance 可能處於的所有可能狀態。
`DagRunState (DAG 執行狀態)`	DagRun 可能處於的所有可能狀態。
`State (狀態)`	具有任務實例狀態常數和顏色方法的靜態類別，以避免硬式編碼。

class airflow.utils.state.JobState[source]¶

繼承自： str, enum.Enum

Job 可能處於的所有可能狀態。

RUNNING = 'running'[source]¶

SUCCESS = 'success'[source]¶

RESTARTING = 'restarting'[source]¶

FAILED = 'failed'[source]¶

__str__()[source]¶

傳回 str(self)。

class airflow.utils.state.TaskInstanceState[source]¶

繼承自： str, enum.Enum

Task Instance 可能處於的所有可能狀態。

請注意，也允許使用 None，因此始終在類型提示中與 Optional 一起使用。

REMOVED = 'removed'[source]¶

SCHEDULED = 'scheduled'[source]¶

QUEUED = 'queued'[source]¶

RUNNING = 'running'[source]¶

SUCCESS = 'success'[source]¶

RESTARTING = 'restarting'[source]¶

FAILED = 'failed'[source]¶

UP_FOR_RETRY = 'up_for_retry'[source]¶

UP_FOR_RESCHEDULE = 'up_for_reschedule'[source]¶

UPSTREAM_FAILED = 'upstream_failed'[source]¶

SKIPPED = 'skipped'[source]¶

DEFERRED = 'deferred'[source]¶

__str__()[source]¶

傳回 str(self)。

class airflow.utils.state.DagRunState[source]¶

繼承自： str, enum.Enum

DagRun 可能處於的所有可能狀態。

這些在程式碼的某些部分與 TaskInstanceState「共用」，因此請確保它們的值始終與 TaskInstanceState 中同名的值匹配。

QUEUED = 'queued'[source]¶

RUNNING = 'running'[source]¶

SUCCESS = 'success'[source]¶

FAILED = 'failed'[source]¶

__str__()[source]¶

傳回 str(self)。

class airflow.utils.state.State[source]¶

具有任務實例狀態常數和顏色方法的靜態類別，以避免硬式編碼。

SUCCESS[source]¶

RUNNING[source]¶

FAILED[source]¶

NONE[source]¶

REMOVED[source]¶

SCHEDULED[source]¶

QUEUED[source]¶

RESTARTING[source]¶

UP_FOR_RETRY[source]¶

UP_FOR_RESCHEDULE[source]¶

UPSTREAM_FAILED[source]¶

SKIPPED[source]¶

DEFERRED[source]¶

finished_dr_states: frozenset[DagRunState][source]¶

unfinished_dr_states: frozenset[DagRunState][source]¶

task_states: tuple[TaskInstanceState | None, Ellipsis] = (None,)[source]¶

dag_states: tuple[DagRunState, Ellipsis] = ()[source]¶

state_color: dict[TaskInstanceState | None, str][source]¶

finished: frozenset[TaskInstanceState][source]¶

指示任務已達到終止狀態（即「已完成」）且不需要進一步動作的狀態列表。

請注意，嘗試可能導致失敗或中斷；或者可能根本沒有運行（跳過或上游失敗），在任何情況下，它都不再運行。

unfinished: frozenset[TaskInstanceState | None][source]¶: 指示任務尚未完成運行或甚至尚未開始的狀態列表。

failed_states: frozenset[TaskInstanceState][source]¶: 指示任務或 DAG 處於失敗狀態的狀態列表。

success_states: frozenset[TaskInstanceState][source]¶: 指示任務或 DAG 處於成功狀態的狀態列表。

adoptable_states[source]¶: 指示任務可以被排程器任務採納或重置的狀態列表，如果任務是由另一個不再運行的排程器任務排隊的。

classmethod color(state)[source]¶: 傳回狀態的顏色。

classmethod color_fg(state)[source]¶: 狀態的黑白顏色。

這個條目有幫助嗎？