• 主页
• 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

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

上一页 下一页

此条目有帮助吗？