Self-healing nightly pipeline: three data products, one Airflow DAG

Apache AirflowTaskGroupsSelf-healingClaude CodeMCPKubernetesntfy

One DAG, three data products in parallel

Airflow DAG daily_data_products: three TaskGroups with all tasks successful

From a failed task to “OK na herstel”

Self-healing loop: Airflow, watcher, phone notification, repair agent, rerun, OK

What really happened in the first nights

Quick checks