我有一个气流DAG,对它进行回填真的没有意义。我计算出,对于气流1.8,你可以给DAG参数
catchup=False
,因此它将只启动最近的作业。
也就是说,我想让DAG在午夜启动,并每天运行。
但是现在的情况是:DAG立即启动,而不是在午夜。此外,当我清除所有DAG运行时,它将立即再次启动。DAG将每天运行,但将安排在错误的时间开始+1天。
我怎么能有一个只开始运行最近作业的DAG,
和
在特定时间(午夜)开始?
以下是我使用的代码:
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
default_args = {'depends_on_past': False,
'start_date': datetime(2013, 1, 1)}
with DAG('test_dag',
default_args=default_args,
schedule_interval=timedelta(days=1),
catchup=False
) as dag:
test = DummyOperator(task_id='test')