From 59c7678b9c9453327cc8f25fbf69a193d86d175f Mon Sep 17 00:00:00 2001 From: Brent Bovenzi Date: Thu, 19 May 2022 22:49:17 -0400 Subject: [PATCH] add comment --- airflow/www/utils.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/www/utils.py b/airflow/www/utils.py index 3d438b781608b0..05f4f2cfe775b4 100644 --- a/airflow/www/utils.py +++ b/airflow/www/utils.py @@ -135,6 +135,7 @@ def encode_ti(dag_run: DagRun, task, session: Session) -> Optional[Dict[str, Any TaskInstance.dag_id == task.dag_id, TaskInstance.run_id == dag_run.run_id, TaskInstance.task_id == task.task_id, + # Only get normal task instances or the first mapped task TaskInstance.map_index <= 0, ) .first()