• 主頁
• Airflow 公共介面
• airflow.utils.state

airflow.utils.state

類

JobState	Job 可能處於的所有狀態。
TerminalTIState	表示 Task Instance 已達到終端狀態的狀態。
IntermediateTIState	表示 Task Instance 尚未處於終端或執行狀態的狀態。
TaskInstanceState	Task Instance 可能處於的所有狀態。
DagRunState	DagRun 可能處於的所有狀態。
State	帶有 task instance 狀態常量和顏色方法的靜態類，用於避免硬編碼。

模組內容

class airflow.utils.state.JobState

Bases: str, enum.Enum

Job 可能處於的所有狀態。

RUNNING = 'running'

SUCCESS = 'success'

RESTARTING = 'restarting'

FAILED = 'failed'

__str__()

返回 str(self)。

class airflow.utils.state.TerminalTIState

Bases: str, enum.Enum

表示 Task Instance 已達到終端狀態的狀態。

SUCCESS = 'success'

FAILED = 'failed'

SKIPPED = 'skipped'

REMOVED = 'removed'

__str__()

返回 str(self)。

class airflow.utils.state.IntermediateTIState

Bases: str, enum.Enum

表示 Task Instance 尚未處於終端或執行狀態的狀態。

SCHEDULED = 'scheduled'

QUEUED = 'queued'

RESTARTING = 'restarting'

UP_FOR_RETRY = 'up_for_retry'

UP_FOR_RESCHEDULE = 'up_for_reschedule'

UPSTREAM_FAILED = 'upstream_failed'

DEFERRED = 'deferred'

__str__()

返回 str(self)。

class airflow.utils.state.TaskInstanceState

Bases: str, enum.Enum

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

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

REMOVED

SCHEDULED

QUEUED

RUNNING = 'running'¶

SUCCESS

RESTARTING

FAILED

UP_FOR_RETRY

UP_FOR_RESCHEDULE

UPSTREAM_FAILED

SKIPPED

DEFERRED

__str__()

返回 str(self)。

class airflow.utils.state.DagRunState

Bases: str, enum.Enum

DagRun 可能處於的所有狀態。

在程式碼的某些部分，這些狀態與 TaskInstanceState 是“共享”的，因此請確保它們的值始終與 TaskInstanceState 中同名狀態的值匹配。

QUEUED = 'queued'

RUNNING = 'running'

SUCCESS = 'success'

FAILED = 'failed'

__str__()

返回 str(self)。

class airflow.utils.state.State

帶有 task instance 狀態常量和顏色方法的靜態類，用於避免硬編碼。

SUCCESS

RUNNING

FAILED

NONE = None

REMOVED

SCHEDULED

QUEUED

RESTARTING

UP_FOR_RETRY

UP_FOR_RESCHEDULE

UPSTREAM_FAILED

SKIPPED

DEFERRED

finished_dr_states: frozenset[DagRunState]

unfinished_dr_states: frozenset[DagRunState]

task_states: tuple[TaskInstanceState | None, Ellipsis]

dag_states: tuple[DagRunState, Ellipsis]

state_color: dict[TaskInstanceState | None, str]

classmethod color(state)

返回狀態對應的顏色。

classmethod color_fg(state)

狀態對應的黑白色。

finished: frozenset[TaskInstanceState]

表示任務已達到終端狀態（即“已完成”）且無需進一步操作的狀態列表。

請注意，嘗試可能已失敗或被中斷；或者可能根本從未執行過（跳過，或 upstream_failed）。無論如何，它不再執行。

unfinished: frozenset[TaskInstanceState | None]

表示任務尚未完成執行或甚至尚未開始的狀態列表。

failed_states: frozenset[TaskInstanceState]

表示任務或 dag 處於失敗狀態的狀態列表。

success_states: frozenset[TaskInstanceState]

表示任務或 dag 處於成功狀態的狀態列表。

adoptable_states

表示任務可以被排程器作業採用或重置的狀態列表，前提是該任務是由不再執行的另一個排程器作業排隊的。

上一頁 下一頁

此條目有幫助嗎？