为什么气流在他完成后立即将dag添加到队列中

Question

我有dag:

args = {
'owner': 'airflow',
'start_date': datetime(2020, 4, 1),
'retries': 1,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'test',
default_args=args,
schedule_interval="@daily",
max_active_runs=1
)

我想每天都跑这个dag，但dag结束后他马上又跑了。请帮忙。

Answer 1

我将start_date更改为当前日期，它起作用：

args = {
'owner': 'airflow',
'start_date': datetime(2020, 11, 27, 13),
'retries': 1,
'retry_delay': timedelta(minutes=1)
}

Answer 2

Dag正在努力赶上当前时间。您可以在dag中将catchup属性设置为False，然后可以给出任何start_date。

https://airflow.apache.org/docs/stable/dag-run.html#catchup