apache/airflow

Metric dag.dag_id.task_id.queued_duration missing

Open

#63.503 geöffnet am 13. März 2026

Auf GitHub ansehen
 (1 Kommentar) (0 Reaktionen) (0 zugewiesene Personen)Python (44.809 Stars) (16.781 Forks)batch import
affected_version:3.1area:corearea:metricsgood first issuekind:bugpriority:upgrade_to_airflow3

Beschreibung

Apache Airflow version

3.1.8

If "Other Airflow 3 version" selected, which one?

No response

What happened?

The metric dag.dag_id.task_id.queued_duration is not being emitted after Airflow 3 upgrade. There are multiple issues like this where metrics are reported missing (we have also noticed ti.finish, ti.start missing, but that has been fixed in 3.1.8).

What you think should happen instead?

All of the metrics that are described in the documentation https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#metric-descriptions should be emitted.

How to reproduce

Run airflow, run task, observe metrics

Operating System

Linux

Versions of Apache Airflow Providers

No response

Deployment

Official Apache Airflow Helm Chart

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Contributor Guide

Tech Stack
python
Domain
observability
Issue Type
bug
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
1-3 hours
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
fresh
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
clear
Voraussetzungen
Airflow metrics systemBasic PythonStatsd protocol
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
75
Research-Richtung
Investigate the Airflow codebase to find where metrics like 'ti.finish' and 'ti.start' are emitted. The metric 'dag id.task id.queued duration' should be added in a similar location. Check the metrics documentation linked in the issue for expected metric names. Look at the fix for 'ti.finish' (likely commit or PR) as a reference. The metric is likely emitted in the task lifecycle code, possibly in the task runner or scheduler.