We currently don't have the best observability into the status of the data processing pipeline runs.
Specifically it would be ideal to collect information on DAG runtimes and learn if some runs have failed.
Airflow supports this by producing otel compatible metrics.
As part of this task we should:
We currently don't have the best observability into the status of the data processing pipeline runs.
Specifically it would be ideal to collect information on DAG runtimes and learn if some runs have failed.
Airflow supports this by producing otel compatible metrics.
As part of this task we should: