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"
}
]
}