Open
Description
Acceptance
- <DAG_ID>/dag_run endpoint on CKAN which gives a report with the status of the DAG
- Collect Airflow default API response for a DAG (for local and remote Airflow instances)
Note: This task won't provide any integration with GCP logs (see #69 ); it only collects the output of Airflow API
Tasks
- Create endpoint; DAG_RUN is optional. If no DAG_RUN is specified, list the most recent dag_runs
- If a DAG run is specified, retrieve info only for that particular RUN (note: when you trigger the DAG, the response brings the DAG_RUN (see /aircan_submit will take the DAG name #79)
- Return Airflow API response (local Airflow)
- Return Airflow API response (remote Airflow). It will require another integration with GCP