如何调度Airflow任务隔日运行？代码可行性及优化方案咨询

代码是否正常工作 #

你给出的代码完全可以正常运行：schedule_interval=timedelta(hours=48)会让DAG每隔48小时触发一次，刚好实现隔日运行的需求。

更优实现方式 #

推荐使用Cron表达式替代timedelta，原因是Cron表达式可读性更强，且能指定固定执行时段，更符合多数调度场景的需求：

• 若需要固定在每日某个时间点隔日运行（比如凌晨2点），可以这样写：

  dag = DAG(  
      dag_name,
      default_args=default_args,
      dagrun_timeout=timedelta(hours=2),
      # Airflow 2.x推荐用schedule参数，兼容旧版schedule_interval
      schedule="0 2 */2 * *"
  )
  

  这个Cron表达式的含义是：每月每2天的凌晨2点0分执行，精准实现隔日固定时段运行。

两种方式的区别 #

• timedelta(hours=48)：以上一次DAG运行结束的时间为起点，往后推48小时触发下一次，适合对执行时间点无严格要求的场景。
• Cron表达式：基于固定时间点触发，不会受上一次运行时长影响，适合需要固定时段执行的任务，维护起来更清晰。

额外注意 #

如果使用的是Airflow 2.x及以上版本，官方推荐使用schedule参数替代旧版的schedule_interval，两者功能兼容，但schedule是未来的标准配置方式。

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