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()