triggers - 气流将任务从下游依赖项或 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
接受失败的原因吗?
任何帮助表示赞赏!谢谢!