首页 > 解决方案 > 气流将任务从下游依赖项或 subdag 之外的参考作业中排除

问题描述

我目前正在尝试在具有许多子依赖项的气流中构建数据管道。我创建了 subdags(和 subsubdags)来实现我想要的功能。但是,我无法弄清楚的一件事是我是否能够从 subdag 中引用下游任务。

我已经包含了数据管道的图片:数据管道

task e需要被触发task c但没有下游依赖。我找不到从 subdag 中更高级别引用任务的方法。有没有办法做到这一点?

作为一种变通方法,现在我刚刚将task e任务 a、b、c 和 d 放在 subdag 中。task f应该在task a, task b, task c, 和task d成功时触发,但无论task e成功还是失败都无关紧要。我可以设置task f有触发器one_failed并指定task_id接受失败的原因吗?

任何帮助表示赞赏!谢谢!

标签: triggersdependenciesairflow

解决方案


推荐阅读