/airflow-maintenance-dags

A series of DAGs/Workflows to help maintain the operation of Airflow

Primary LanguagePythonApache License 2.0Apache-2.0

airflow-maintenance-dags

A series of DAGs/Workflows to help maintain the operation of Airflow

DAGs/Workflows

  • db-cleanup
    • A maintenance workflow that you can deploy into Airflow to periodically clean out the DagRun, TaskInstance, Log, XCom, Job DB and SlaMiss entries to avoid having too much data in your Airflow MetaStore.
  • kill-halted-tasks
    • A maintenance workflow that you can deploy into Airflow to periodically kill off tasks that are running in the background that don't correspond to a running task in the DB.
    • This is useful because when you kill off a DAG Run or Task through the Airflow Web Server, the task still runs in the background on one of the executors until the task is complete.
  • log-cleanup
    • A maintenance workflow that you can deploy into Airflow to periodically clean out the task logs to avoid those getting too big.