• Home
• Public Interface of Airflow
• airflow.exceptions

airflow.exceptions

Exceptions used by Airflow.

Module Contents

Classes

FileSyntaxError

Information about a single error in a file.

exception airflow.exceptions.AirflowException

Bases: Exception

Base class for all Airflow’s errors.

Each custom exception should be derived from this class.

status_code

serialize()

exception airflow.exceptions.AirflowBadRequest

Bases: AirflowException

Raise when the application or server cannot handle the request.

status_code

exception airflow.exceptions.AirflowNotFoundException

Bases: AirflowException

Raise when the requested object/resource is not available in the system.

status_code

exception airflow.exceptions.AirflowConfigException

Bases: AirflowException

Raise when there is configuration problem.

exception airflow.exceptions.AirflowSensorTimeout

Bases: AirflowException

Raise when there is a timeout on sensor polling.

exception airflow.exceptions.AirflowRescheduleException(reschedule_date)

Bases: AirflowException

Raise when the task should be re-scheduled at a later time.

Parameters

reschedule_date – The date when the task should be rescheduled

serialize()

exception airflow.exceptions.InvalidStatsNameException

Bases: AirflowException

Raise when name of the stats is invalid.

exception airflow.exceptions.AirflowTaskTimeout

Bases: BaseException

Raise when the task execution times-out.

exception airflow.exceptions.AirflowTaskTerminated

Bases: BaseException

Raise when the task execution is terminated.

exception airflow.exceptions.AirflowWebServerTimeout

Bases: AirflowException

Raise when the web server times out.

exception airflow.exceptions.AirflowSkipException

Bases: AirflowException

Raise when the task should be skipped.

exception airflow.exceptions.AirflowFailException

Bases: AirflowException

Raise when the task should be failed without retrying.

exception airflow.exceptions.AirflowOptionalProviderFeatureException

Bases: AirflowException

Raise by providers when imports are missing for optional provider features.

exception airflow.exceptions.XComNotFound(dag_id, task_id, key)

Bases: AirflowException

Raise when an XCom reference is being resolved against a non-existent XCom.

__str__()

Return str(self).

serialize()

exception airflow.exceptions.UnmappableOperator

Bases: AirflowException

Raise when an operator is not implemented to be mappable.

exception airflow.exceptions.XComForMappingNotPushed

Bases: AirflowException

Raise when a mapped downstream’s dependency fails to push XCom for task mapping.

__str__()

Return str(self).

exception airflow.exceptions.UnmappableXComTypePushed(value, *values)

Bases: AirflowException

Raise when an unmappable type is pushed as a mapped downstream’s dependency.

__str__()

Return str(self).

exception airflow.exceptions.UnmappableXComLengthPushed(value, max_length)

Bases: AirflowException

Raise when the pushed value is too large to map as a downstream’s dependency.

__str__()

Return str(self).

exception airflow.exceptions.AirflowDagCycleException

Bases: AirflowException

Raise when there is a cycle in DAG definition.

exception airflow.exceptions.AirflowDagDuplicatedIdException(dag_id, incoming, existing)

Bases: AirflowException

Raise when a DAG’s ID is already used by another DAG.

__str__()

Return str(self).

exception airflow.exceptions.AirflowClusterPolicyViolation

Bases: AirflowException

Raise when there is a violation of a Cluster Policy in DAG definition.

exception airflow.exceptions.AirflowClusterPolicySkipDag

Bases: AirflowException

Raise when skipping dag is needed in Cluster Policy.

exception airflow.exceptions.AirflowClusterPolicyError

Bases: AirflowException

Raise for a Cluster Policy other than AirflowClusterPolicyViolation or AirflowClusterPolicySkipDag.

exception airflow.exceptions.AirflowTimetableInvalid

Bases: AirflowException

Raise when a DAG has an invalid timetable.

exception airflow.exceptions.DagNotFound

Bases: AirflowNotFoundException

Raise when a DAG is not available in the system.

exception airflow.exceptions.DagCodeNotFound

Bases: AirflowNotFoundException

Raise when a DAG code is not available in the system.

exception airflow.exceptions.DagRunNotFound

Bases: AirflowNotFoundException

Raise when a DAG Run is not available in the system.

exception airflow.exceptions.DagRunAlreadyExists(dag_run)

Bases: AirflowBadRequest

Raise when creating a DAG run for DAG which already has DAG run entry.

serialize()

exception airflow.exceptions.DagFileExists(*args, **kwargs)

Bases: AirflowBadRequest

Raise when a DAG ID is still in DagBag i.e., DAG file is in DAG folder.

exception airflow.exceptions.FailStopDagInvalidTriggerRule

Bases: AirflowException

Raise when a dag has ‘fail_stop’ enabled yet has a non-default trigger rule.

__str__()

Return str(self).

exception airflow.exceptions.DuplicateTaskIdFound

Bases: AirflowException

Raise when a Task with duplicate task_id is defined in the same DAG.

exception airflow.exceptions.TaskAlreadyInTaskGroup(task_id, existing_group_id, new_group_id)

Bases: AirflowException

Raise when a Task cannot be added to a TaskGroup since it already belongs to another TaskGroup.

__str__()

Return str(self).

exception airflow.exceptions.SerializationError

Bases: AirflowException

A problem occurred when trying to serialize something.

exception airflow.exceptions.ParamValidationError

Bases: AirflowException

Raise when DAG params is invalid.

exception airflow.exceptions.TaskNotFound

Bases: AirflowNotFoundException

Raise when a Task is not available in the system.

exception airflow.exceptions.TaskInstanceNotFound

Bases: AirflowNotFoundException

Raise when a task instance is not available in the system.

exception airflow.exceptions.PoolNotFound

Bases: AirflowNotFoundException

Raise when a Pool is not available in the system.

class airflow.exceptions.FileSyntaxError

Bases: NamedTuple

Information about a single error in a file.

line_no: int | None

message: str

__str__()

Return str(self).

exception airflow.exceptions.AirflowFileParseException(msg, file_path, parse_errors)

Bases: AirflowException

Raises when connection or variable file can not be parsed.

Parameters

• msg (str) – The human-readable description of the exception

• file_path (str) – A processed file that contains errors

• parse_errors (list[FileSyntaxError]) – File syntax errors

__str__()

Return str(self).

exception airflow.exceptions.ConnectionNotUnique

Bases: AirflowException

Raise when multiple values are found for the same connection ID.

exception airflow.exceptions.TaskDeferred(*, trigger, method_name, kwargs=None, timeout=None)

Bases: BaseException

Signal an operator moving to deferred state.

Special exception raised to signal that the operator it was raised from wishes to defer until a trigger fires. Triggers can send execution back to task or end the task instance directly. If the trigger should end the task instance itself, method_name does not matter, and can be None; otherwise, provide the name of the method that should be used when resuming execution in the task.

serialize()

__repr__()

Return repr(self).

exception airflow.exceptions.TaskDeferralError

Bases: AirflowException

Raised when a task failed during deferral for some reason.

exception airflow.exceptions.TaskDeferralTimeout

Bases: AirflowException

Raise when there is a timeout on the deferral.

exception airflow.exceptions.PodMutationHookException

Bases: AirflowException

Raised when exception happens during Pod Mutation Hook execution.

exception airflow.exceptions.PodReconciliationError

Bases: AirflowException

Raised when an error is encountered while trying to merge pod configs.

exception airflow.exceptions.RemovedInAirflow3Warning

Bases: DeprecationWarning

Issued for usage of deprecated features that will be removed in Airflow3.

deprecated_since: str | None

Indicates the airflow version that started raising this deprecation warning

exception airflow.exceptions.AirflowProviderDeprecationWarning

Bases: DeprecationWarning

Issued for usage of deprecated features of Airflow provider.

deprecated_provider_since: str | None

Indicates the provider version that started raising this deprecation warning

exception airflow.exceptions.DeserializingResultError

Bases: ValueError

Raised when an error is encountered while a pickling library deserializes a pickle file.

__str__()

Return str(self).

exception airflow.exceptions.UnknownExecutorException

Bases: ValueError

Raised when an attempt is made to load an executor which is not configured.

Previous Next

Was this entry helpful?