We currently have a hybrid pipeline airflow setup. The core of airflow is being hosted on k8s with replicants.
I want to simulate node failures to ensure the replication and fault tolerance is working as expected for airflow and the dags being run. It's critical that our pipeline fails gracefully and I would like structured tests for it.
Besides manually turning off nodes for my cluster, how can I systematically simulate failures and track their impact on production?