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

Question

我有狗：

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
)

我想每天 airflow 运行这个 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

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

Why airflow add dag to queue immediately after he finish?

python

cron

airflow

airflow-scheduler