airflow_priority.plugins.newrelicΒΆ Functions get_client() on_dag_run_failed(dag_run, msg) on_dag_run_running(dag_run, msg) on_dag_run_success(dag_run, msg) send_metric_newrelic(dag_id, priority, tag) Classes NewRelicPriorityPlugin()