Статус задачи Apache Airflow DAG - веб-api

У вас может быть задача, которая проверит базу данных воздушного потока на task_instance.state. У вас может быть задача или отдельный DAG, который будет искать статус dag в базе данных, которую вы хотите проверить, на определенную дату выполнения.

Я столкнулся с такой же потребностью, используя Airflow 1.10.12, и решил ее с помощью этой службы:

GET /api/experimental/dags/<string:dag_id>/dag_runs/<string:execution_date>

Он вернет JSON в этом формате:

{"state":"running"}