Priority Tags for Airflow Dags
This repo provides an Airflow Plugin for priority-driven DAG failure alerting.
In layman's terms, one need only add a tag to their DAG in P1, P2, P3, P4, P5
, where P1
corresponds to highest priority and P5
corresponds to lowest, and that dag will send a notification to a backend integration.
See the documentation for more information on getting started
Integration | Metric / Tag | Docs |
---|---|---|
![]() |
airflow.priority.p{1,2,3,4,5}.{failed,succeeded,running} |
Link |
![]() |
N/A |
Link |
![]() |
airflow.priority.p{1,2,3,4,5}.{failed,succeeded,running} |
Link |
![]() |
N/A |
Link |
![]() |
airflow.priority.p{1,2,3,4,5}.{failed,succeeded,running} |
Link |
![]() |
N/A |
Link |
![]() |
N/A |
Link |
![]() |
N/A |
Link |
AWS Cloudwatch | airflow.priority.p{1,2,3,4,5}.{failed,succeeded,running} |
Link |
You can install from pip:
pip install airflow-priority
Or via conda:
conda install airflow-priority -c conda-forge
This software is licensed under the Apache 2.0 license. See the LICENSE file for details.