diff --git a/airflow/providers/elasticsearch/log/es_task_handler.py b/airflow/providers/elasticsearch/log/es_task_handler.py index 85f8b1f15a456..bb19130e7d104 100644 --- a/airflow/providers/elasticsearch/log/es_task_handler.py +++ b/airflow/providers/elasticsearch/log/es_task_handler.py @@ -134,7 +134,7 @@ def _render_log_id(self, ti: TaskInstance, try_number: int) -> str: data_interval_end=data_interval_end, execution_date=execution_date, try_number=try_number, - map_index=ti.map_index, + map_index=getattr(ti, "map_index", ""), ) @staticmethod