我有一个每天运行的DAG,我对它做了一些更改,我需要重新运行它几个月。
如果我进入气流界面,我可以清除它,它就会运行,但这需要点击很多次。还有别的办法吗?如果我像这样从命令行进行回填:
airflow backfill -s 20200101 -e 20200301 daily_dag_name
这实际上不会运行dag,我相信这是因为它运行成功,而回填只有在失败时才会工作。
由于执行日期已经有DAG运行,因此没有什么需要回填的。您需要的是清除那些将在给定时间段内重新触发运行的DAG运行:
airflow tasks clear -s 20200101 -e 20200301 daily_dag_name