`airflow.models.dagwarning`¶

Module Contents¶

Classes¶

`DagWarning`	A table to store DAG warnings.
`DagWarningType`	Enum for DAG warning types.

class airflow.models.dagwarning.DagWarning(dag_id, error_type, message, **kwargs)[source]¶

Bases: airflow.models.base.Base

A table to store DAG warnings.

DAG warnings are problems that don’t rise to the level of failing the DAG parse but which users should nonetheless be warned about. These warnings are recorded when parsing DAG and displayed on the Webserver in a flash message.

dag_id[source]¶

warning_type[source]¶

message[source]¶

timestamp[source]¶

__tablename__ = dag_warning[source]¶

__table_args__[source]¶

__eq__(other)[source]¶

__hash__()[source]¶

classmethod purge_inactive_dag_warnings(session=NEW_SESSION)[source]¶

Deactivate DagWarning records for inactive dags.

Returns: None
Return type: None

class airflow.models.dagwarning.DagWarningType[source]¶

Bases: str, enum.Enum

Enum for DAG warning types.

This is the set of allowable values for the warning_type field in the DagWarning model.

NONEXISTENT_POOL = non-existent pool[source]¶

airflow.models.dagwarning¶

Module Contents¶

Classes¶

`airflow.models.dagwarning`¶