如何修改已部署DAG的schedule_interval参数?
关于Airflow修改DAG调度间隔的问题
- 默认情况下,修改
schedule_interval需要重新部署DAG脚本,因为Airflow调度器会定期解析本地DAG文件,将配置同步到元数据库中,只有脚本更新后,新的调度间隔才会被持久化识别。 - 存在临时修改的CLI命令(Airflow 2.x及以上版本支持),无需修改脚本即可生效,但该变更仅存在于元数据库中,不会同步到本地脚本:
使用airflow dags patch命令直接修改元数据中的调度配置:
例如设置每5分钟执行一次:airflow dags patch <你的DAG_ID> --set schedule_interval="你的新调度表达式"airflow dags patch my_dag --set schedule_interval="*/5 * * * *" - 注意:这种方式属于临时变更,当Airflow重新解析DAG文件(如部署新脚本、调度器重启、执行
airflow dags reserialize)时,元数据库中的配置会被脚本里的原始值覆盖。若要永久修改,仍需更新DAG脚本并重新部署。
内容的提问来源于stack exchange,提问作者Pavel Orekhov
相关产品推荐
相关产品推荐

