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-priorityOr via conda:
conda install airflow-priority -c conda-forgeThis software is licensed under the Apache 2.0 license. See the LICENSE file for details.
Note
This library was generated using copier from the Base Python Project Template repository.







