• 主页
• Airflow 的公共接口
• airflow.utils.state

airflow.utils.state

模块内容

类

JobState	作业可能处于的所有可能状态。
TaskInstanceState	任务实例可能处于的所有可能状态。
DagRunState	DagRun 可能处于的所有可能状态。
State	具有任务实例状态常量和颜色方法的静态类，以避免硬编码。

class airflow.utils.state.JobState

基类: str, enum.Enum

作业可能处于的所有可能状态。

RUNNING = 'running'

SUCCESS = 'success'

RESTARTING = 'restarting'

FAILED = 'failed'

__str__()

返回 str(self)。

class airflow.utils.state.TaskInstanceState

基类: str, enum.Enum

任务实例可能处于的所有可能状态。

请注意，也允许使用 None，因此请始终在类型提示中使用 Optional。

REMOVED = 'removed'

SCHEDULED = 'scheduled'

QUEUED = 'queued'

RUNNING = 'running'

SUCCESS = 'success'

RESTARTING = 'restarting'

FAILED = 'failed'

UP_FOR_RETRY = 'up_for_retry'

UP_FOR_RESCHEDULE = 'up_for_reschedule'

UPSTREAM_FAILED = 'upstream_failed'

SKIPPED = 'skipped'

DEFERRED = 'deferred'

__str__()

返回 str(self)。

class airflow.utils.state.DagRunState

基类: str, enum.Enum

DagRun 可能处于的所有可能状态。

这些在代码的某些部分与 TaskInstanceState “共享”，因此请确保它们的值始终与 TaskInstanceState 中同名的值匹配。

QUEUED = 'queued'

RUNNING = 'running'

SUCCESS = 'success'

失败 = 'failed'

__str__()

返回 str(self)。

类 airflow.utils.state.状态

具有任务实例状态常量和颜色方法的静态类，以避免硬编码。

成功

运行中

失败

无

已移除

已调度

已入队

重启中

等待重试

等待重新调度

上游失败

已跳过

已延迟

finished_dr_states: frozenset[DagRunState]

unfinished_dr_states: frozenset[DagRunState]

task_states: tuple[TaskInstanceState | None, ...] = (None,)

dag_states: tuple[DagRunState, ...] = ()

state_color: dict[TaskInstanceState | None, str]

finished: frozenset[TaskInstanceState]

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

请注意，尝试可能导致失败或中断；或者可能根本没有运行（跳过或上游失败），在任何情况下，它都不再运行。

unfinished: frozenset[TaskInstanceState | None]

表示任务尚未完成运行甚至尚未启动的状态列表。

failed_states: frozenset[TaskInstanceState]

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

success_states: frozenset[TaskInstanceState]

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

adoptable_states

一些状态的列表，这些状态表明，如果任务是由另一个已停止运行的调度器作业排队的，那么该任务可以被调度器作业采用或重置。

classmethod color(state)

返回状态的颜色。

classmethod color_fg(state)

返回状态的黑白颜色。

上一个 下一个

此条目是否有帮助？