The GitHub Actions job "Tests (AMD)" on airflow.git/fix-queued-duration-metric-63503 has failed. Run started by GitHub user myps6415 (triggered by potiuk).
Head commit for run: 2988b046a1cf5e9a2cdce48080629530d8da320a / 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 on transitions that are not the genuine first run of a try: - retry of a previous attempt, identified by an existing end_date; - resume from deferral, identified by next_method (the trigger sets it and end_date stays None across a deferral, so end_date alone cannot catch it); - missing queued_dttm (rare race / test setups). Report URL: https://github.com/apache/airflow/actions/runs/26928684107 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
