airflow.exceptions¶

Airflow 使用的异常。

异常¶

`AirflowException`	所有 Airflow 错误的基类。
`AirflowBadRequest`	当应用或服务器无法处理请求时引发。
`AirflowNotFoundException`	当系统找不到请求的对象/资源时引发。
`AirflowConfigException`	当存在配置问题时引发。
`AirflowSensorTimeout`	当 Sensor 轮询超时时引发。
`AirflowRescheduleException`	当任务应在稍后时间重新调度时引发。
`InvalidStatsNameException`	当统计信息名称无效时引发。
`AirflowTaskTimeout`	当任务执行超时时引发。
`AirflowTaskTerminated`	当任务执行被终止时引发。
`AirflowWebServerTimeout`	当 Web 服务器超时时引发。
`AirflowSkipException`	当任务应被跳过时引发。
`AirflowFailException`	当任务应失败且不重试时引发。
`AirflowInactiveAssetInInletOrOutletException`	当任务在其输入（inlet）或输出（outlet）中包含非活跃资产时引发。
`AirflowOptionalProviderFeatureException`	当可选 Provider 功能所需的导入缺失时，由 Provider 引发。
`XComNotFound`	当对不存在的 XCom 解析 XCom 引用时引发。
`XComForMappingNotPushed`	当 mapped 的下游依赖未能为任务映射推送 XCom 时引发。
`UnmappableXComTypePushed`	当推送了一个不可映射的类型作为 mapped 下游依赖时引发。
`UnmappableXComLengthPushed`	当推送的值过大无法作为 mapped 下游依赖进行映射时引发。
`AirflowDagCycleException`	当 DAG 定义中存在循环时引发。
`AirflowDagDuplicatedIdException`	当 DAG ID 已被另一个 DAG 使用时引发。
`AirflowClusterPolicyViolation`	当 DAG 定义中违反集群策略时引发。
`AirflowClusterPolicySkipDag`	当集群策略中需要跳过 DAG 时引发。
`AirflowClusterPolicyError`	针对 AirflowClusterPolicyViolation 或 AirflowClusterPolicySkipDag 以外的集群策略引发。
`AirflowTimetableInvalid`	当 DAG 具有无效的时间表时引发。
`DagNotFound`	当系统找不到 DAG 时引发。
`DagCodeNotFound`	当系统找不到 DAG 代码时引发。
`DagRunNotFound`	当系统找不到 DAG Run 时引发。
`DagRunAlreadyExists`	当为已存在 DAG run 条目的 DAG 创建 DAG run 时引发。
`DagFileExists`	当 DAG ID 仍在 DagBag 中（即 DAG 文件位于 DAG 文件夹中）时引发。
`FailFastDagInvalidTriggerRule`	当 DAG 启用了 'fail_fast' 但使用了非默认的 trigger rule 时引发。
`DuplicateTaskIdFound`	当在同一 DAG 中定义了具有重复 task_id 的任务时引发。
`TaskAlreadyInTaskGroup`	当任务已属于另一个 TaskGroup 而无法添加到当前 TaskGroup 时引发。
`SerializationError`	尝试序列化某物时发生问题。
`ParamValidationError`	当 DAG 参数无效时引发。
`TaskNotFound`	当系统找不到任务时引发。
`TaskInstanceNotFound`	当系统找不到任务实例时引发。
`PoolNotFound`	当系统找不到 Pool 时引发。
`AirflowFileParseException`	当连接或变量文件无法解析时引发。
`ConnectionNotUnique`	当为同一连接 ID 找到多个值时引发。
`DownstreamTasksSkipped`	Operator 发出信号以跳过其下游任务。
`DagRunTriggerException`	Operator 发出信号以触发 DAG 的特定 Dag Run。
`TaskDeferred`	表示 Operator 进入延迟状态。
`TaskDeferralError`	当任务在延迟期间因某种原因失败时引发。
`TaskDeferralTimeout`	当延迟超时时引发。
`PodMutationHookException`	在 Pod Mutation Hook 执行期间发生异常时引发。
`PodReconciliationError`	尝试合并 pod 配置时遇到错误时引发。
`RemovedInAirflow4Warning`	针对 Airflow 4 中将移除的已弃用功能的使用发出。
`AirflowProviderDeprecationWarning`	针对 Airflow Provider 的已弃用功能的使用发出。
`DeserializingResultError`	当 pickling 库反序列化 pickle 文件时遇到错误时引发。
`UnknownExecutorException`	尝试加载未配置的 Executor 时引发。

类¶

FileSyntaxError

有关文件中单个错误的信息。

模块内容¶

exception airflow.exceptions.AirflowException[source]¶

基类： Exception

所有 Airflow 错误的基类。

每个自定义异常都应派生自此类。

status_code[source]¶

serialize()[source]¶

exception airflow.exceptions.AirflowBadRequest[source]¶

基类： AirflowException

当应用或服务器无法处理请求时引发。

status_code[source]¶

exception airflow.exceptions.AirflowNotFoundException[source]¶

基类： AirflowException

当系统找不到请求的对象/资源时引发。

status_code[source]¶

exception airflow.exceptions.AirflowConfigException[source]¶

基类： AirflowException

当存在配置问题时引发。

exception airflow.exceptions.AirflowSensorTimeout[source]¶

基类： AirflowException

当 Sensor 轮询超时时引发。

exception airflow.exceptions.AirflowRescheduleException(reschedule_date)[source]¶

基类： AirflowException

当任务应在稍后时间重新调度时引发。

参数：: reschedule_date – 任务应重新调度的日期

reschedule_date[source]¶

serialize()[source]¶

exception airflow.exceptions.InvalidStatsNameException[source]¶

基类： AirflowException

当统计信息名称无效时引发。

exception airflow.exceptions.AirflowTaskTimeout[source]¶

基类： BaseException

当任务执行超时时引发。

exception airflow.exceptions.AirflowTaskTerminated[source]¶

基类： BaseException

当任务执行被终止时引发。

exception airflow.exceptions.AirflowWebServerTimeout[source]¶

基类： AirflowException

当 Web 服务器超时时引发。

exception airflow.exceptions.AirflowSkipException[source]¶

基类： AirflowException

当任务应被跳过时引发。

exception airflow.exceptions.AirflowFailException[source]¶

基类： AirflowException

当任务应失败且不重试时引发。

exception airflow.exceptions.AirflowInactiveAssetInInletOrOutletException(inactive_asset_keys)[source]¶

基类： _AirflowExecuteWithInactiveAssetExecption

当任务在其输入（inlet）或输出（outlet）中包含非活跃资产时引发。

main_message = 'Task has the following inactive assets in its inlets or outlets'[source]¶

exception airflow.exceptions.AirflowOptionalProviderFeatureException[source]¶

基类： AirflowException

当可选 Provider 功能所需的导入缺失时，由 Provider 引发。

exception airflow.exceptions.XComNotFound(dag_id, task_id, key)[source]¶

基类： AirflowException

当对不存在的 XCom 解析 XCom 引用时引发。

dag_id[source]¶

task_id[source]¶

key[source]¶

__str__()[source]¶

返回 str(self)。

serialize()[source]¶

exception airflow.exceptions.XComForMappingNotPushed[source]¶

基类： AirflowException

当 mapped 的下游依赖未能为任务映射推送 XCom 时引发。

__str__()[source]¶

返回 str(self)。

exception airflow.exceptions.UnmappableXComTypePushed(value, *values)[source]¶

基类： AirflowException

当推送了一个不可映射的类型作为 mapped 下游依赖时引发。

__str__()[source]¶

返回 str(self)。

exception airflow.exceptions.UnmappableXComLengthPushed(value, max_length)[source]¶

基类： AirflowException

当推送的值过大无法作为 mapped 下游依赖进行映射时引发。

value[source]¶

max_length[source]¶

__str__()[source]¶

返回 str(self)。

exception airflow.exceptions.AirflowDagCycleException[source]¶

基类： AirflowException

当 DAG 定义中存在循环时引发。

exception airflow.exceptions.AirflowDagDuplicatedIdException(dag_id, incoming, existing)[source]¶

基类： AirflowException

当 DAG ID 已被另一个 DAG 使用时引发。

dag_id[source]¶

incoming[source]¶

existing[source]¶

__str__()[source]¶

返回 str(self)。

exception airflow.exceptions.AirflowClusterPolicyViolation[source]¶

基类： AirflowException

当 DAG 定义中违反集群策略时引发。

exception airflow.exceptions.AirflowClusterPolicySkipDag[source]¶

基类： AirflowException

当集群策略中需要跳过 DAG 时引发。

exception airflow.exceptions.AirflowClusterPolicyError[source]¶

基类： AirflowException

针对 AirflowClusterPolicyViolation 或 AirflowClusterPolicySkipDag 以外的集群策略引发。

exception airflow.exceptions.AirflowTimetableInvalid[source]¶

基类： AirflowException

当 DAG 具有无效的时间表时引发。

exception airflow.exceptions.DagNotFound[source]¶

基类： AirflowNotFoundException

当系统找不到 DAG 时引发。

exception airflow.exceptions.DagCodeNotFound[source]¶

基类： AirflowNotFoundException

当系统找不到 DAG 代码时引发。

exception airflow.exceptions.DagRunNotFound[source]¶

基类： AirflowNotFoundException

当系统找不到 DAG Run 时引发。

exception airflow.exceptions.DagRunAlreadyExists(dag_run)[source]¶

基类： AirflowBadRequest

当为已存在 DAG run 条目的 DAG 创建 DAG run 时引发。

dag_run[source]¶

serialize()[source]¶

exception airflow.exceptions.DagFileExists(*args, **kwargs)[source]¶

基类： AirflowBadRequest

当 DAG ID 仍在 DagBag 中（即 DAG 文件位于 DAG 文件夹中）时引发。

exception airflow.exceptions.FailFastDagInvalidTriggerRule[source]¶

基类： AirflowException

当 dag 启用了 ‘fail_fast’ 但使用了非默认触发规则时引发此异常。

__str__()[source]¶

返回 str(self)。

exception airflow.exceptions.DuplicateTaskIdFound[source]¶

基类： AirflowException

当在同一 DAG 中定义了具有重复 task_id 的任务时引发。

exception airflow.exceptions.TaskAlreadyInTaskGroup(task_id, existing_group_id, new_group_id)[source]¶

基类： AirflowException

当任务已属于另一个 TaskGroup 而无法添加到当前 TaskGroup 时引发。

task_id[source]¶

existing_group_id[source]¶

new_group_id[source]¶

__str__()[source]¶

返回 str(self)。

exception airflow.exceptions.SerializationError[source]¶

基类： AirflowException

尝试序列化某物时发生问题。

exception airflow.exceptions.ParamValidationError[source]¶

基类： AirflowException

当 DAG 参数无效时引发。

exception airflow.exceptions.TaskNotFound[source]¶

基类： AirflowNotFoundException

当系统找不到任务时引发。

exception airflow.exceptions.TaskInstanceNotFound[source]¶

基类： AirflowNotFoundException

当系统找不到任务实例时引发。

exception airflow.exceptions.PoolNotFound[source]¶

基类： AirflowNotFoundException

当系统找不到 Pool 时引发。

class airflow.exceptions.FileSyntaxError[source]¶

基类: NamedTuple

有关文件中单个错误的信息。

line_no: int | None[source]¶

message: str[source]¶

__str__()[source]¶

exception airflow.exceptions.AirflowFileParseException(msg, file_path, parse_errors)[source]¶

基类： AirflowException

当连接或变量文件无法解析时引发。

参数：

msg (str) – 异常的可读描述信息
file_path (str) – 包含错误的处理文件
parse_errors (list[FileSyntaxError]) – 文件语法错误

msg[source]¶

file_path[source]¶

parse_errors[source]¶

__str__()[source]¶: 返回 str(self)。

exception airflow.exceptions.ConnectionNotUnique[source]¶

基类： AirflowException

当为同一连接 ID 找到多个值时引发。

exception airflow.exceptions.DownstreamTasksSkipped(*, tasks)[source]¶

基类： AirflowException

Operator 发出信号以跳过其下游任务。

引发的特殊异常，表示抛出此异常的 Operator 希望跳过其下游任务。这用于 ShortCircuitOperator。

参数：: tasks (collections.abc.Sequence[str | tuple[str, int]]) – 要跳过的 task_id 列表或包含要跳过的 task_id 和 map_index 的元组列表。

tasks[source]¶

exception airflow.exceptions.DagRunTriggerException(*, trigger_dag_id, dag_run_id, conf, logical_date, reset_dag_run, skip_when_already_exists, wait_for_completion, allowed_states, failed_states, poke_interval, deferrable)[source]¶