时间戳

首页 > 解决方案 > 避免气流中的过期日期

airflow - 避免气流中的过期日期

问题描述

我有以下气流 DAG：

from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator

#Runs every 1 minute
dag = DAG(dag_id='example_dag', start_date=datetime(2020, 1, 1), schedule_interval='*/1 * * * *')

t1 = BashOperator(task_id='bash_task', bash_command='echo Hello!', dag=dag)

这里的问题是 Airflow 正在调度和执行过去日期的任务，例如 2020 年的第一分钟、2020 年的第二分钟、2020 年的第三分钟等等。

我希望 Airflow 仅调度和执行 dag 部署之后发生的任务（即，如果我今天部署，我希望在下一分钟执行第一个任务）而不执行过期任务。

有什么建议吗？谢谢！

标签： airflowairflow-scheduler

解决方案

我在这里找到了答案。阅读“追赶和幂等 DAG”部分。

推荐阅读