如何解决如何在同一 DAG 中每小时安排一个任务和其他任务
我想知道是否可以在单个 DAG 中使用不同的调度程序,我解释了我的用例:每天午夜执行的任务以创建一个文件(每个天),其他任务将每小时执行一次以追加数据到文件中。
你注意到我有两个 scheduler_interval
0 * * * *
(每小时)=> 追加数据
有解决这个问题的想法吗?
解决方法
您可以使用 python 分支运算符来解决您的问题。这个python分支操作符将检查当前时间是否是午夜然后去创建一个文件任务否则去任务将数据附加到文件中。调度程序应该每小时一次。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。