aircan
aircan copied to clipboard
Endpoint for dag_run status
Acceptance
- [x] <DAG_ID>/dag_run endpoint on CKAN which gives a report with the status of the DAG
- [x] 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
- [x] Create endpoint; DAG_RUN is optional. If no DAG_RUN is specified, list the most recent dag_runs
- [x] 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 #79)
- [x] Return Airflow API response (local Airflow)
- [x] Return Airflow API response (remote Airflow). It will require another integration with GCP
@hannelita could you update this issue quickly with some info on what status is and update e.g. acceptance with links to outputs / items justifying the completion status.
Then if everything is done can you closed as FIXED with a brief note 😄