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