The GitHub Actions job "Tests (AMD)" on airflow.git/fix-queued-duration-metric-63503 has succeeded. Run started by GitHub user myps6415 (triggered by eladkal).
Head commit for run: 0f3fb972df053c168ebabd28efead95329a92ed9 / JohnTung <[email protected]> Fix missing task.queued_duration metric in Airflow 3 task.queued_duration (and its registry-derived legacy name dag.<dag_id>.<task_id>.queued_duration) stopped firing after the Airflow 3 worker switched to the Task SDK / supervisor / Execution API. The only emit site was TaskInstance.emit_state_change_metric, reachable solely from the legacy LocalTaskJob path, while Airflow 3 workers flip the TI to RUNNING through the ti_run Execution API endpoint instead. Emit it from ti_run on the genuine QUEUED -> RUNNING transition, tagged via DagRun.stats_tags so the restored metric stays sliceable the same way as its sibling task.scheduled_duration (dag_id, task_id, queue, run_type, team_name under multi-team, and Dag tags when configured). Resumes from deferral are skipped so a deferral cycle does not add a second sample inside the same try. closes: #63503 closes: #66067 Report URL: https://github.com/apache/airflow/actions/runs/30874493529 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
