如果以前的触发器仍在运动，如何使气流DAG跳过一个小时
一个简单的气流DAG开发问题
args = {
'owner': 'Airflow',
'start_date': dates.days_ago(1),
'email': ['[email protected]', '[email protected]'],
'email_on_failure': True,
'email_on_success': True,
'schedule_interval': '0 * * * *',
}
上述配置指出，DAG应每小时在小时的顶部运行。
如果以前的工作仍在运动，该如何使工作跳过一小时？
谢谢！
A simple question for airflow DAG development
args = {
'owner': 'Airflow',
'start_date': dates.days_ago(1),
'email': ['[email protected]', '[email protected]'],
'email_on_failure': True,
'email_on_success': True,
'schedule_interval': '0 * * * *',
}
The above configuration states that the DAG should run every hour on the top of the hour.
How do I make the job skip one hour if the previous job is still in motion?
Thanks!
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
如评论中所述，您可以通过设置
max_active_runs = 1来实现所需的目标。但是，这将取决于预期行为的更广泛背景。如果您需要更复杂的时间表，请考虑实施自己的 nofollow noreferrer /a>。
As mentioned in comment you can achieve what you want by setting
max_active_runs=1. However, this will depend on wider context of expected behaviour.If you need more complex schedule consider implementing your own Timetable.