如果在 DAG 上设置了未来日期,则在 airflow 1.10.1 中无法手动 运行
if future date is set on a DAG, manual run is not possible in airflow 1.10.1
在 Airflow 1.8 的早期版本中,我们的团队能够手动 运行 DAG,即使 start_date 被设置为未来的日期。在我们使用 celery.
集群设置将 Airflow 升级到 1.10.1 后,现在不会发生这种情况
Airflow 版本之间有什么变化吗?
是的,有一个changelog available for reference and the apache jira for the project airflow can show you all the those tickets which will have comments for their github pull requests. You can review changes in each pull request, or you can take a look at the diff in tags。您可能对调度程序更改感兴趣,因为这将检查是否可以安排任务,尽管它可能在 celery 执行程序或作业中 运行ner 进行双重检查。
看起来 intent 不是 运行 未来的工作。
文档说您可以 运行 具有未来执行日期的 dag。
必须在 airflow.cfg
中启用 allow_trigger_in_future
标记
allow_trigger_in_future
New in version 1.10.8.
Allow externally triggered DagRuns for Execution Dates in the future Only has effect if schedule_interval is set to None in DAG
Type
string
Default
False
Environment Variable
AIRFLOW__SCHEDULER__ALLOW_TRIGGER_IN_FUTURE
在 Airflow 1.8 的早期版本中,我们的团队能够手动 运行 DAG,即使 start_date 被设置为未来的日期。在我们使用 celery.
集群设置将 Airflow 升级到 1.10.1 后,现在不会发生这种情况Airflow 版本之间有什么变化吗?
是的,有一个changelog available for reference and the apache jira for the project airflow can show you all the those tickets which will have comments for their github pull requests. You can review changes in each pull request, or you can take a look at the diff in tags。您可能对调度程序更改感兴趣,因为这将检查是否可以安排任务,尽管它可能在 celery 执行程序或作业中 运行ner 进行双重检查。
看起来 intent 不是 运行 未来的工作。
文档说您可以 运行 具有未来执行日期的 dag。
必须在 airflow.cfg
中启用 allow_trigger_in_future
标记
allow_trigger_in_future
New in version 1.10.8.
Allow externally triggered DagRuns for Execution Dates in the future Only has effect if schedule_interval is set to None in DAG
Type
string
Default
False
Environment Variable
AIRFLOW__SCHEDULER__ALLOW_TRIGGER_IN_FUTURE