AirFlow - X 连续失败后禁用 dag

Question

我阅读了 API 参考资料，但在其中找不到任何内容，这可能吗？

Answer 1

目前，没有这种开箱即用的功能，但您可以在 DAG 中编写一些自定义代码来解决这个问题。例如，使用 PythonOperator（如果元数据数据库是 mysql，则可以使用 MySQL 运算符）获取 dag 的最后 X 运行s 的状态。 使用 BranchPythonOperator 查看数字是否大于 X，如果超过 X，则使用 BashOperator 到 运行 airflow pause dag cli.

您也可以通过在 BranchPythonOperator 中添加 PythonOperator 的逻辑使其成为两步任务。这只是一个想法，你可以使用不同的逻辑。