airflow_priority.plugins.slack

Functions

get_channel_id()
get_client()
on_dag_run_failed(dag_run, msg)
send_metric_slack(dag_id, priority, tag)

Classes

SlackPriorityPlugin()