Prakshal Jain

@kaxil Are these changes compatible with Airflow 1.8 and 1.9 as well?

@chetkhatri the DAG task deletes logs on the node on which it is running so that's the reason why only logs on worker nodes are being removed. You can try...

Resolved by #116

What version of Airflow are you using?

Hi, Could you try downloading the latest version of [airflow-log-cleanup.py](https://github.com/teamclairvoyant/airflow-maintenance-dags/blob/master/log-cleanup/airflow-log-cleanup.py)? I just tried running it locally and it seems to be working fine. Below are the logs from the run....

- [x] Remove methods that cant be reused - [x] Rename any DF vars to have either _dag_, _daily_, _hourly - [x] Remove hardcoded 1,3,7 days - [ ] Loop...