Return DAG Run Through

For Airflow version 1.10.0 and older:

GET /airflow-webserver-<cluster-id>/api/experimental/latest_runs

For Airflow 1.10.2 and later:

GET /airflow-rbacwebserver-<cluster-id>/api/experimental/latest_runs

You can return the latest Dag Run for each DAG formatted for the UI through this experimental API.

Note

To run the experimental APIs, you require to have Airflow version 1.10.0 and above.

Required Role

A user with read permission to the cluster can make this API call.

Syntax

curl -X GET \  https://<ENV>.qubole.com/airflow-rbacwebserver-<Cluster-ID>/api/experimental/latest_runs \

Note

You need to specify the QDS environment in the above syntax. It works with all the environments described in Supported Qubole Endpoints on Different Cloud Providers.

Sample Query

curl -X GET \  https://api.qubole.com/airflow-rbacwebserver-94461/api/experimental/latest_runs \
  -H "Accept: application/json"
  -H 'Cache-Control: no-cache' \
  -H 'Content-Type: application/json' \
  -H 'X-AUTH-TOKEN: <AUTH_TOKEN>'\
  -d '{}'

Sample Response

{
 "items":
 [
   {
     "dag_id": "dag_test",
     "dag_run_url": "/airflow-rbacwebserver-94461/graph?execution_date=2019-11-20+09%3A23%3A24.524713%2B00%3A00&dag_id=dag_test",
     "execution_date": "2019-11-20T09:23:24.524713+00:00",
     "start_date": "2019-11-20T09:23:24.538530+00:00"
   }
 ]
}