airflow.exceptions

Airflow 使用的异常。

模块内容

类

FileSyntaxError

有关文件中单个错误的信息。
exception airflow.exceptions.AirflowException[源代码]

基类: Exception

所有 Airflow 错误的基本类。

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

status_code[源代码]
serialize()[源代码]
exception airflow.exceptions.AirflowBadRequest[源代码]

基类: AirflowException

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

status_code[源代码]
exception airflow.exceptions.AirflowNotFoundException[源代码]

基类: AirflowException

当系统中没有请求的对象/资源时引发。

status_code[源代码]
exception airflow.exceptions.AirflowConfigException[源代码]

基类: AirflowException

当存在配置问题时引发。

exception airflow.exceptions.AirflowSensorTimeout[源代码]

基类: AirflowException

当传感器轮询超时时引发。

exception airflow.exceptions.AirflowRescheduleException(reschedule_date)[源代码]

基类: AirflowException

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

参数

reschedule_date – 任务应重新调度的日期

serialize()[源代码]
exception airflow.exceptions.InvalidStatsNameException[源代码]

基类: AirflowException

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

exception airflow.exceptions.AirflowTaskTimeout[源代码]

基类: BaseException

当任务执行超时时引发。

exception airflow.exceptions.AirflowTaskTerminated[源代码]

基类: BaseException

当任务执行终止时引发。

exception airflow.exceptions.AirflowWebServerTimeout[源代码]

基类: AirflowException

当 Web 服务器超时时引发。

exception airflow.exceptions.AirflowSkipException[源代码]

基类: AirflowException

当任务应被跳过时引发。

exception airflow.exceptions.AirflowFailException[源代码]

基类: AirflowException

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

异常 airflow.exceptions.AirflowOptionalProviderFeatureException[源]

基类: AirflowException

当可选提供程序功能缺少导入时，由提供程序引发。

异常 airflow.exceptions.XComNotFound(dag_id, task_id, key)[源]

基类: AirflowException

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

__str__()[源]

返回 str(self)。

serialize()[源]
异常 airflow.exceptions.UnmappableOperator[源]

基类: AirflowException

当操作符未实现为可映射时引发。

异常 airflow.exceptions.XComForMappingNotPushed[源]

基类: AirflowException

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

__str__()[源]

返回 str(self)。

异常 airflow.exceptions.UnmappableXComTypePushed(value, *values)[源]

基类: AirflowException

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

__str__()[源]

返回 str(self)。

异常 airflow.exceptions.UnmappableXComLengthPushed(value, max_length)[源]

基类: AirflowException

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

__str__()[源]

返回 str(self)。

异常 airflow.exceptions.AirflowDagCycleException[源]

基类: AirflowException

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

异常 airflow.exceptions.AirflowDagDuplicatedIdException(dag_id, incoming, existing)[源]

基类: AirflowException

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

__str__()[源]

返回 str(self)。

异常 airflow.exceptions.AirflowDagInconsistent[源]

基类: AirflowException

当 DAG 具有不一致的属性时引发。

异常 airflow.exceptions.AirflowClusterPolicyViolation[源]

基类: AirflowException

当 DAG 定义中存在集群策略违规时引发。

异常 airflow.exceptions.AirflowClusterPolicySkipDag[源]

基类: AirflowException

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

异常 airflow.exceptions.AirflowClusterPolicyError[源]

基类: AirflowException

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

异常 airflow.exceptions.AirflowTimetableInvalid[源]

基类: AirflowException

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

异常 airflow.exceptions.DagNotFound[源]

基类：AirflowNotFoundException

当系统中没有 DAG 可用时引发。

异常 airflow.exceptions.DagCodeNotFound[源]

基类：AirflowNotFoundException

当系统中没有 DAG 代码可用时引发。

异常 airflow.exceptions.DagRunNotFound[源]

基类：AirflowNotFoundException

当系统中没有 DAG Run 可用时引发。

异常 airflow.exceptions.DagRunAlreadyExists(dag_run, execution_date, run_id)[源]

基类：AirflowBadRequest

当为已具有 DAG 运行条目的 DAG 创建 DAG 运行条目时引发。

serialize()[源]
异常 airflow.exceptions.DagFileExists(*args, **kwargs)[源代码]

基类：AirflowBadRequest

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

异常 airflow.exceptions.FailStopDagInvalidTriggerRule[源代码]

基类: AirflowException

当 DAG 启用了 ‘fail_stop’ 但具有非默认触发规则时引发。

__str__()[源代码]

返回 str(self)。

异常 airflow.exceptions.DuplicateTaskIdFound[源代码]

基类: AirflowException

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

异常 airflow.exceptions.TaskAlreadyInTaskGroup(task_id, existing_group_id, new_group_id)[源代码]

基类: AirflowException

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

__str__()[源代码]

返回 str(self)。

异常 airflow.exceptions.SerializationError[源代码]

基类: AirflowException

尝试序列化某些内容时发生问题。

异常 airflow.exceptions.ParamValidationError[源代码]

基类: AirflowException

当 DAG 参数无效时引发。

异常 airflow.exceptions.TaskNotFound[源代码]

基类：AirflowNotFoundException

当系统中没有可用的任务时引发。

异常 airflow.exceptions.TaskInstanceNotFound[源代码]

基类：AirflowNotFoundException

当系统中没有可用的任务实例时引发。

异常 airflow.exceptions.PoolNotFound[源代码]

基类：AirflowNotFoundException

当系统中没有可用的池时引发。

异常 airflow.exceptions.NoAvailablePoolSlot[源代码]

基类: AirflowException

当池中没有足够的槽位时引发。

异常 airflow.exceptions.DagConcurrencyLimitReached[源代码]

基类: AirflowException

当达到 DAG max_active_tasks 限制时引发。

异常 airflow.exceptions.TaskConcurrencyLimitReached[源代码]

基类: AirflowException

当达到任务 max_active_tasks 限制时引发。

异常 airflow.exceptions.BackfillUnfinished(message, ti_status)[源代码]

基类: AirflowException

当回填中并非所有任务都成功时引发。

参数

  • message – 异常的人类可读描述

  • ti_status – 关于所有任务状态的信息

类 airflow.exceptions.FileSyntaxError[源代码]

基类：NamedTuple

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

line_no: int | None[源代码]
message: str[源代码]
__str__()[源代码]

返回 str(self)。

异常 airflow.exceptions.AirflowFileParseException(msg, file_path, parse_errors)[源代码]

基类: AirflowException

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

参数

  • msg (str) – 异常的人类可读描述

  • file_path (str) – 包含错误的已处理文件

  • parse_errors (list[FileSyntaxError]) – 文件语法错误

__str__()[源代码]

返回 str(self)。

异常 airflow.exceptions.ConnectionNotUnique[源代码]

基类: AirflowException

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

异常 airflow.exceptions.TaskDeferred(*, trigger, method_name, kwargs=None, timeout=None)[源代码]

基类: BaseException

发出一个运算符正在移动到延迟状态的信号。

抛出特殊异常，以表示抛出该异常的操作符希望延迟执行，直到触发器触发。触发器可以将执行返回给任务，或直接结束任务实例。如果触发器应结束任务实例本身，则 method_name 无关紧要，可以为 None；否则，请提供在任务中恢复执行时应使用的方法名称。

serialize()[source]
__repr__()[source]

返回 repr(self)。

exception airflow.exceptions.TaskDeferralError[source]

基类: AirflowException

当任务在延迟执行期间由于某种原因失败时引发。

exception airflow.exceptions.PodMutationHookException[source]

基类: AirflowException

在 Pod 突变 Hook 执行期间发生异常时引发。

exception airflow.exceptions.PodReconciliationError[source]

基类: AirflowException

在尝试合并 pod 配置时遇到错误时引发。

exception airflow.exceptions.RemovedInAirflow3Warning[source]

基类：DeprecationWarning

针对将在 Airflow3 中删除的已弃用功能的使用发出。

deprecated_since: str | None[source]

指示开始引发此弃用警告的 airflow 版本

exception airflow.exceptions.AirflowProviderDeprecationWarning[source]

基类：DeprecationWarning

针对 Airflow provider 的已弃用功能的使用发出。

deprecated_provider_since: str | None[source]

指示开始引发此弃用警告的 provider 版本

exception airflow.exceptions.DeserializingResultError[source]

基类：ValueError

当 pickle 库反序列化 pickle 文件时遇到错误时引发。

__str__()[source]

返回 str(self)。

exception airflow.exceptions.UnknownExecutorException[source]

基类：ValueError

当尝试加载未配置的执行器时引发。

此条目是否对您有帮助？