Airflow配置正确cron表达式后DAG意外在0点触发如何解决

你的 cron 表达式本身逻辑是符合需求的，出现额外0点触发的问题，基本是以下3种常见原因导致：

• 时区配置不匹配（最高概率）
  Airflow 默认使用UTC时区，你编写的0 9,12,16,19 * * 1-6表达式默认会按UTC时间解析，UTC时间加8小时为东八区时间，其中UTC 16点对应东八区的24点也就是0点，就会出现你观察到的额外0点触发的情况。
• 历史任务回填触发
  Airflow DAG默认开启catchup参数，如果你的start_date设置为早于当前时间的过去日期，Airflow会自动补跑start_date到当前时间之间所有缺失的DAG Run，这类回填任务容易被误认为是新调度规则触发的多余任务。
• 旧调度规则残留
  如果该DAG之前配置过包含0点的调度规则，修改规则后没有清空Airflow元数据库中已经生成的待执行DAG Run，旧规则的任务仍然会按原定时间触发。

对应解决方案 #

1. 校准时区：在DAG定义中显式指定对应时区，示例配置如下：

from datetime import datetime
from airflow import DAG

default_args = {
    "start_date": datetime(2024, 1, 1),
    "retries": 1
}

with DAG(
    dag_id="your_dag_name",
    default_args=default_args,
    schedule_interval="0 9,12,16,19 * * 1-6",
    timezone="Asia/Shanghai", # 替换为你实际使用的时区
    catchup=False,
    tags=["your_business_tag"]
) as dag:
    # 此处编写你的任务逻辑

如果需要全局生效，也可以修改airflow.cfg配置文件中的default_timezone参数为对应时区，重启Airflow所有服务后生效。
2. 关闭历史回填：在DAG参数中设置catchup=False，避免Airflow自动补跑历史任务。如果已经生成了多余的待执行回填任务，可以在Airflow WebUI的Browse > DAG Runs页面手动筛选删除。
3. 清空残留任务：修改DAG调度规则后，建议先暂停DAG，删除所有状态为queued、scheduled的待执行任务，再重新启用DAG，避免旧规则的残留任务触发。

内容的提问来源于stack exchange，提问作者user14285538