API reference airflow_priority.plugin airflow_priority.plugin¶ Functions on_dag_run_failed(dag_run, msg) on_dag_run_running(dag_run, msg) on_dag_run_success(dag_run, msg) Classes AirflowPriorityPlugin() Previous airflow_priority.common Next airflow_priority.tracker.Tracker