apache/airflow

Metric dag.dag_id.task_id.queued_duration missing

Open

#63.503 aberto em 13 de mar. de 2026

Ver no GitHub
 (1 comment) (0 reactions) (0 assignees)Python (44.809 stars) (16.781 forks)batch import
affected_version:3.1area:corearea:metricsgood first issuekind:bugpriority:upgrade_to_airflow3

Description

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

Guia do colaborador

Pilha de tecnologia
python
Domain
observability
Tipo Issue
bug
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
1-3 hours
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
fresh
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
clear
Prerequisites
Airflow metrics systemBasic PythonStatsd protocol
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
75
Direção de pesquisa
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.