如何在Airflow中配置Cron实现指定季度日期定时任务？现有表达式异常

一、实现每年1/4/7/10月3日UTC 11:00执行的Cron表达式 #

要让任务在每年1月3日、4月3日、7月3日、10月3日UTC时间11:00执行，正确的Cron表达式为：

0 11 3 1,4,7,10 *

各字段解释：

• 0：分钟为0
• 11：小时为11（UTC时间）
• 3：日期为3号
• 1,4,7,10：指定1、4、7、10月
• *：任意星期几

将其配置到DAG的schedule_interval参数即可：

schedule_interval="0 11 3 1,4,7,10 *"

二、排查schedule_interval="0 11 22 1/3 *"未按计划运行的问题 #

针对你提供的表达式，可按以下步骤逐一排查：

• 验证时区配置：确认Airflow部署的default_timezone（在airflow.cfg中）设置为utc，若时区非UTC，会导致任务执行时间偏移。
• 核对Cron表达式逻辑：1/3表示从1月开始每3个月（即1、4、7、10月），日字段22合法，这部分逻辑没问题，但可手动确认表达式是否符合预期（比如检查是否存在月份天数限制，1/4/7/10月都有22号，无问题）。
• 检查DAG的start_date：Airflow的调度逻辑依赖start_date计算首次执行时间。若start_date设置在当月22号之后，首次执行会延迟到下一个周期的22号。例如start_date=datetime(2024,1,23)，首次运行会是2024年4月22日。
• 确认DAG状态：在Airflow UI中检查DAG是否处于启用状态，若DAG被暂停，调度器不会生成任务实例。
• 查看调度器日志：检查Airflow调度器的日志，搜索目标DAG名称，排查是否存在调度错误（如时间解析失败、任务实例创建异常等）。
• 检查任务实例状态：在Airflow UI的Graph View或Tree View中查看任务实例的状态，确认是否存在scheduled但未执行、queued卡住或failed的情况，排查执行环境问题（如worker资源不足、依赖缺失）。

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