airflow_priority.plugins.aws¶

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_cloudwatch`(dag_id, priority, tag)

Classes

AWSCloudWatchPriorityPlugin()