• Home
• Python API Reference
• airflow.exceptions

airflow.exceptions

Exceptions used by Airflow

Module Contents

exception airflow.exceptions.AirflowException

Bases: Exception

Base class for all Airflow's errors. Each custom exception should be derived from this class

status_code = 500

exception airflow.exceptions.AirflowBadRequest

Bases: airflow.exceptions.AirflowException

Raise when the application or server cannot handle the request

status_code = 400

exception airflow.exceptions.AirflowNotFoundException

Bases: airflow.exceptions.AirflowException, airflow.api_connexion.exceptions.NotFound

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

status_code = 404

exception airflow.exceptions.AirflowConfigException

Bases: airflow.exceptions.AirflowException

Raise when there is configuration problem

exception airflow.exceptions.AirflowSensorTimeout

Bases: airflow.exceptions.AirflowException

Raise when there is a timeout on sensor polling

exception airflow.exceptions.AirflowRescheduleException(reschedule_date)

Bases: airflow.exceptions.AirflowException

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

Parameters

reschedule_date (datetime.datetime) -- The date when the task should be rescheduled

exception airflow.exceptions.AirflowSmartSensorException

Bases: airflow.exceptions.AirflowException

Raise after the task register itself in the smart sensor service It should exit without failing a task

exception airflow.exceptions.InvalidStatsNameException

Bases: airflow.exceptions.AirflowException

Raise when name of the stats is invalid

exception airflow.exceptions.AirflowTaskTimeout

Bases: airflow.exceptions.AirflowException

Raise when the task execution times-out

exception airflow.exceptions.AirflowWebServerTimeout

Bases: airflow.exceptions.AirflowException

Raise when the web server times out

exception airflow.exceptions.AirflowSkipException

Bases: airflow.exceptions.AirflowException

Raise when the task should be skipped

exception airflow.exceptions.AirflowFailException

Bases: airflow.exceptions.AirflowException

Raise when the task should be failed without retrying

exception airflow.exceptions.AirflowDagCycleException

Bases: airflow.exceptions.AirflowException

Raise when there is a cycle in Dag definition

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

Bases: airflow.exceptions.AirflowException

Raise when a Dag's ID is already used by another Dag

__str__(self)

exception airflow.exceptions.AirflowClusterPolicyViolation

Bases: airflow.exceptions.AirflowException

Raise when there is a violation of a Cluster Policy in Dag definition

exception airflow.exceptions.AirflowTimetableInvalid

Bases: airflow.exceptions.AirflowException

Raise when a DAG has an invalid timetable.

exception airflow.exceptions.DagNotFound

Bases: airflow.exceptions.AirflowNotFoundException

Raise when a DAG is not available in the system

exception airflow.exceptions.DagCodeNotFound

Bases: airflow.exceptions.AirflowNotFoundException

Raise when a DAG code is not available in the system

exception airflow.exceptions.DagRunNotFound

Bases: airflow.exceptions.AirflowNotFoundException

Raise when a DAG Run is not available in the system

exception airflow.exceptions.DagRunAlreadyExists

Bases: airflow.exceptions.AirflowBadRequest

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

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

Bases: airflow.exceptions.AirflowBadRequest

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

exception airflow.exceptions.DuplicateTaskIdFound

Bases: airflow.exceptions.AirflowException

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

exception airflow.exceptions.SerializationError

Bases: airflow.exceptions.AirflowException

A problem occurred when trying to serialize a DAG

exception airflow.exceptions.TaskNotFound

Bases: airflow.exceptions.AirflowNotFoundException

Raise when a Task is not available in the system

exception airflow.exceptions.TaskInstanceNotFound

Bases: airflow.exceptions.AirflowNotFoundException

Raise when a Task Instance is not available in the system

exception airflow.exceptions.PoolNotFound

Bases: airflow.exceptions.AirflowNotFoundException

Raise when a Pool is not available in the system

exception airflow.exceptions.NoAvailablePoolSlot

Bases: airflow.exceptions.AirflowException

Raise when there is not enough slots in pool

exception airflow.exceptions.DagConcurrencyLimitReached

Bases: airflow.exceptions.AirflowException

Raise when DAG max_active_tasks limit is reached

exception airflow.exceptions.TaskConcurrencyLimitReached

Bases: airflow.exceptions.AirflowException

Raise when task max_active_tasks limit is reached

exception airflow.exceptions.BackfillUnfinished(message, ti_status)

Bases: airflow.exceptions.AirflowException

Raises when not all tasks succeed in backfill.

Parameters

• message -- The human-readable description of the exception

• ti_status -- The information about all task statuses

class airflow.exceptions.FileSyntaxError

Bases: typing.NamedTuple

Information about a single error in a file.

line_no :Optional[int]

message :str

__str__(self)

exception airflow.exceptions.AirflowFileParseException(msg: str, file_path: str, parse_errors: List[FileSyntaxError])

Bases: airflow.exceptions.AirflowException

Raises when connection or variable file can not be parsed

Parameters

• msg -- The human-readable description of the exception

• file_path -- A processed file that contains errors

• parse_errors -- File syntax errors

__str__(self)

exception airflow.exceptions.ConnectionNotUnique

Bases: airflow.exceptions.AirflowException

Raise when multiple values are found for the same conn_id

exception airflow.exceptions.TaskDeferred(*, trigger, method_name: str, kwargs: Optional[Dict[str, Any]] = None, timeout: Optional[datetime.timedelta] = None)

Bases: BaseException

Special exception raised to signal that the operator it was raised from wishes to defer until a trigger fires.

__repr__(self)

exception airflow.exceptions.TaskDeferralError

Bases: airflow.exceptions.AirflowException

Raised when a task failed during deferral for some reason.

Previous Next

Was this entry helpful?