aircan icon indicating copy to clipboard operation
aircan copied to clipboard

Endpoint for dag_run status

Open hannelita opened this issue 3 years ago • 1 comments

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 avatar Jul 28 '20 11:07 hannelita