Apache airflow Состояние задачи DAG - веб-интерфейс

Question

Есть ли способ получить текущее состояние самого последнего запуска DAG через API Airflow?Я попробовал экспериментальный API с этим:

/api/experimental/dags/<DAG_ID>/tasks/<TASK_ID> 

Но это только дает информацию о задаче, а не статус каждого запуска.По сути, мне нужно иметь возможность получить результат самого последнего запуска задачи - успех, неудача, постановка в очередь и т. Д.

Answer 1

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