2025 年 Airflow 峰会将于 10 月 07-09 日举行。立即注册获取早鸟票!

airflow.utils.state

JobState

Job 可能处于的所有状态。

TerminalTIState

表示 Task Instance 已达到终端状态的状态。

IntermediateTIState

表示 Task Instance 尚未处于终端或运行状态的状态。

TaskInstanceState

Task Instance 可能处于的所有状态。

DagRunState

DagRun 可能处于的所有状态。

State

带有 task instance 状态常量和颜色方法的静态类,用于避免硬编码。

模块内容

class airflow.utils.state.JobState[source]

Bases: str, enum.Enum

Job 可能处于的所有状态。

RUNNING = 'running'[source]
SUCCESS = 'success'[source]
RESTARTING = 'restarting'[source]
FAILED = 'failed'[source]
__str__()[source]

返回 str(self)。

class airflow.utils.state.TerminalTIState[source]

Bases: str, enum.Enum

表示 Task Instance 已达到终端状态的状态。

SUCCESS = 'success'[source]
FAILED = 'failed'[source]
SKIPPED = 'skipped'[source]
REMOVED = 'removed'[source]
__str__()[source]

返回 str(self)。

class airflow.utils.state.IntermediateTIState[source]

Bases: str, enum.Enum

表示 Task Instance 尚未处于终端或运行状态的状态。

SCHEDULED = 'scheduled'[source]
QUEUED = 'queued'[source]
RESTARTING = 'restarting'[source]
UP_FOR_RETRY = 'up_for_retry'[source]
UP_FOR_RESCHEDULE = 'up_for_reschedule'[source]
UPSTREAM_FAILED = 'upstream_failed'[source]
DEFERRED = 'deferred'[source]
__str__()[source]

返回 str(self)。

class airflow.utils.state.TaskInstanceState[source]

Bases: str, enum.Enum

Task Instance 可能处于的所有状态。

请注意,None 也允许,因此始终在类型提示中与 Optional 一起使用此项。

REMOVED[source]
SCHEDULED[source]
QUEUED[source]
RUNNING = 'running'[source]
SUCCESS[source]
RESTARTING[source]
FAILED[source]
UP_FOR_RETRY[source]
UP_FOR_RESCHEDULE[source]
UPSTREAM_FAILED[source]
SKIPPED[source]
DEFERRED[source]
__str__()[source]

返回 str(self)。

class airflow.utils.state.DagRunState[source]

Bases: 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]

带有 task instance 状态常量和颜色方法的静态类,用于避免硬编码。

SUCCESS[source]
RUNNING[source]
FAILED[source]
NONE = 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][source]
dag_states: tuple[DagRunState, Ellipsis][source]
state_color: dict[TaskInstanceState | None, str][source]
classmethod color(state)[source]

返回状态对应的颜色。

classmethod color_fg(state)[source]

状态对应的黑白色。

finished: frozenset[TaskInstanceState][source]

表示任务已达到终端状态(即“已完成”)且无需进一步操作的状态列表。

请注意,尝试可能已失败或被中断;或者可能根本从未运行过(跳过,或 upstream_failed)。无论如何,它不再运行。

unfinished: frozenset[TaskInstanceState | None][source]

表示任务尚未完成运行或甚至尚未开始的状态列表。

failed_states: frozenset[TaskInstanceState][source]

表示任务或 dag 处于失败状态的状态列表。

success_states: frozenset[TaskInstanceState][source]

表示任务或 dag 处于成功状态的状态列表。

adoptable_states[source]

表示任务可以被调度器作业采用或重置的状态列表,前提是该任务是由不再运行的另一个调度器作业排队的。

此条目有帮助吗?