从dags文件夹中删除多个DAG文件后,需要为每个DAG运行airflow delete_dag dag_id
,或者从web UI中逐个删除DAG条目。
与其这样做,是否有一种功能或命令可以一次性清除已删除的DAG?
您可以直接对Airflow数据库执行查询;我们有一个Airflow过程,它通过从log
、task_fail
等中删除条目来定期清理我们的数据库。
与对数据库进行更改一样,请确保您有备份。