如何解决气流sql_sensors如何解释来自独立DAG的跳过的任务?
我希望在DAG 1中使用ShortCircuit运算符,以便在给定日期没有可用数据时跳过DAG运行。
我有一个DAG 2,它使用sql_sensors触发DAG 1并检查各个DAG 1任务的状态。这些传感器阻止DAG 2继续运行,直到它们识别出它正在DAG 1中检查的关联任务成功为止。
我的问题是,如果DAG 1在给定的一天短路,并且所有下游任务都设置为“已跳过”,DAG 2上的sql_sensor将如何解释跳过的任务?它会认为它们是“成功”并继续进行下游任务吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。