Cron 作业在气流中的错误日期运行答案

【问题标题】：Cron job running on wrong date in airflowCron 作业在气流中的错误日期运行
【发布时间】：2021-10-02 15:17:18
【问题描述】：

我的 dag 是这样的：

args = {
    'owner': 'Me',
    'depends_on_past': False,
    'start_date': datetime(2021, 6, 16),
    'retries': 1,
    'retry_delay': timedelta(seconds=100),
    'provide_context': True
}

dag = DAG(
    dag_id='my_dag',
    default_args=args,
    catchup=False,
    schedule_interval='0 6 25 * *'
)

作为参考，今天是 2021 年 7 月 26 日。使用我定义的 schedule_interval，我希望它在每个月的 25 日早上 6 点运行。但是，昨天（25 日）运行时，dag 执行日期设置为 6 月 25 日早上 6 点。

为什么？我预计执行日期是 7/25。跟我的 start_date 有关系吗？

【问题讨论】：

标签： python cron airflow

【解决方案1】：

在 Airflow 中，DAG 在调度间隔的结束运行。 execution_date 是执行期间的日期，而start_date 是 DAG/任务开始执行的日期。在您的情况下，execution_date 是 6/25，因为那是执行期的日期。 start_date 将是 7/25。

execution_date 是旧 ETL 作业调度的保留，您可以在其中汇总一个周期结束时的数据。

【讨论】：

您是说我需要将 start_date 更改为 7/25 吗？我试过了，还是不行。