The GitHub Actions job "Tests (AMD)" on airflow.git/fix-queued-duration-metric-63503 has succeeded. Run started by GitHub user myps6415 (triggered by potiuk).
Head commit for run: 7ce2ef2083ab78766cbfd50c48828705712881a3 / John Tung <[email protected]> Fix missing task.queued_duration metric in Airflow 3 The metric was only emitted by TaskInstance.emit_state_change_metric, which was only called from the legacy LocalTaskJob path (_check_and_change_state_before_execution). Airflow 3 workers run via the Task SDK and supervisor, which flip TI state to RUNNING through the ti_run Execution API endpoint instead — that path bypassed the emit site, so task.queued_duration (and its registry-derived legacy name dag.<dag_id>.<task_id>.queued_duration) stopped firing entirely. Emit the metric from the ti_run endpoint at the same moment it flips state from QUEUED to RUNNING. Skip the emit when end_date is already set (deferral resume) or queued_dttm is missing, mirroring the existing guards in emit_state_change_metric. Report URL: https://github.com/apache/airflow/actions/runs/26497118096 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
