如何定义不应定期运行的Airflow DAG /任务

Question

目标非常简单:我需要为不应定期运行的手动任务创建DAG,但仅在管理员按下"运行"按钮时才需要.理想情况下,无需切换"取消暂停"和"暂停"DAG(您知道有人肯定会忘记暂停).

到目前为止我只是来过schedule_interval="0 0 30 2 *"(2月30日希望永远不会发生),但必须有更好的方法!

在那儿？

Answer 1

根据文档,您可以将调度程序预设设置为None(不计划,仅用于"外部触发"DAG).此外,@once如果只安排一次,您可以将其设置为.

Answer 2

放schedule_interval=None。

例如：

from airflow import models

with models.DAG(
    'Your DAG',
    schedule_interval=None,
    start_date=datetime(2021, 1, 1)
) as dag:
...