| :py:mod:`airflow.models.dagwarning` |
| =================================== |
| |
| .. py:module:: airflow.models.dagwarning |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.models.dagwarning.DagWarning |
| airflow.models.dagwarning.DagWarningType |
| |
| |
| |
| |
| .. py:class:: DagWarning(dag_id, error_type, message, **kwargs) |
| |
| Bases: :py:obj:`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. |
| |
| .. py:attribute:: dag_id |
| |
| |
| |
| |
| .. py:attribute:: warning_type |
| |
| |
| |
| |
| .. py:attribute:: message |
| |
| |
| |
| |
| .. py:attribute:: timestamp |
| |
| |
| |
| |
| .. py:attribute:: __tablename__ |
| :annotation: = dag_warning |
| |
| |
| |
| .. py:attribute:: __table_args__ |
| |
| |
| |
| |
| .. py:method:: __eq__(other) |
| |
| |
| .. py:method:: __hash__() |
| |
| |
| .. py:method:: purge_inactive_dag_warnings(session = NEW_SESSION) |
| :classmethod: |
| |
| Deactivate DagWarning records for inactive dags. |
| |
| :return: None |
| |
| |
| |
| .. py:class:: DagWarningType |
| |
| Bases: :py:obj:`str`, :py:obj:`enum.Enum` |
| |
| Enum for DAG warning types. |
| |
| This is the set of allowable values for the ``warning_type`` field |
| in the DagWarning model. |
| |
| .. py:attribute:: NONEXISTENT_POOL |
| :annotation: = non-existent pool |
| |
| |
| |
| |
