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

34

目标很简单:我需要为手动任务创建一个DAG,该任务不应定期运行,但只有在管理员按下“运行”按钮时才能运行。最好不需要切换DAG的“暂停”和“取消暂停”(您知道肯定会有人忘记暂停)。

到目前为止,我只想到了schedule_interval="0 0 30 2 *"(希望从未出现过30日2月),但一定有更好的方法吧!

有吗?


7
让我因为“修复2月30日的问题”笑了起来。 - PdevG
2个回答

47
基于文档,你可以将调度器预设为None(不进行调度,仅用于“外部触发”DAG)。另外,如果只需调度一次,则可以将其设置为@once

1
太棒了!我没注意到。我真丢脸;) 谢谢! - Ikar Pohorský

8

schedule_interval=None 设置。

例如:

from airflow import models

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

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接