python - 气流设置 dag 取决于过去与触发规则
问题描述
我有一个设置depends_on_past=True 的dag。因此,对于大多数任务,我们希望它保持不变。而一个特定的任务A,我们设置trigger_rule="one_failed"
问题是。这个任务 A 并不总是被触发,因为它的父母并不总是失败。但是如果它不是每天都被触发(比如我们每天都安排),那么就不会满足depends_on_past 条件。
意义。如果第 1 天没有运行。然后第 2 天,如果任务失败,它就不会运行!
如何将此 BashOperator 设置为忽略 depends_on_past 规则?
解决方案
您可以覆盖depends_on_past
特定任务实例的参数。因此,在您的情况下,任务 A 的定义可以覆盖depends_on_past=False
,而 DAG 中的其余任务仍以depends_on_past=True
.
推荐阅读
- reactjs - 尝试将我的 REACT Webpack 应用程序部署到 heroku。一切都在本地工作,heroku 构建工作。但我得到一个 404 nginx
- python - GPSD 未响应新连接
- excel - 从一个工作簿复制到另一个工作簿时缺少命名范围
- python - PowerBI .pbix DataMashup 压缩目录
- azure - 在 Rest API 中使用通配符列出 Azure 数据湖存储中的文件
- java - 如何将 String[] 转换为 Point for TouchAction 命令
- php - php dom从循环中获取多个元素
- assembly - msp430 中的汇编否定
- ios - SwiftUI:滚动视图中的顶部锚定可调整大小视图
- java - Java预实例化数组