Airflow 是Airbnb公司開源的，是用 Python 實現的任務管理、調度、監控工作流的平臺。因依調度賴於 crontab ，Airflow 目前只支持在安裝在 Linux 系統平臺。Airflow 可以用做 data pipeline（ETL）、 消息隊列等監控。

airflow官網
airflow-github

安裝airflow參考鏈接

刪除一些失敗記錄

登錄到airflow的數據庫後執行SQL語句

SELECT * FROM `dag_run` WHERE dag_id=‘adv_data_16min‘ and state=‘failed‘

DELETE FROM `dag_run` WHERE dag_id=‘adv_data_16min‘ and state=‘failed‘

SELECT * FROM `dag_stats` WHERE dag_id=‘adv_data_16min‘ and state=‘failed‘

DELETE FROM `dag_stats` WHERE dag_id=‘adv_data_16min‘ and state=‘failed‘
 

airflow1.8.0 刪除近期執行失敗的記錄