我在 Google Cloud Composer 上运行了一个 DAG。这个 DAG 正在我们的 BigQuery 之上执行一些操作（我们正在使用airflow.contrib.operators.bigquery_operator.BigQueryOperator）如果 DAG 出现故障，我想调用错误报告 API，但是，我不知道该怎么做。
问问题
78 次
1 回答
1
答案是使用on_failure_callbackDAG args 中的参数。这是一篇关于如何使用它的非常好的入门级文章：https ://forum.astronomer.io/t/how-can-i-set-my-on-failure-and-on-success-callbacks-to -拥有任务上下文/182
于 2021-06-22T07:48:13.050 回答