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]¶