This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new db02dc1b28e Add map_index_template to MappedOperator (#54648)
db02dc1b28e is described below
commit db02dc1b28eab3e7b59d9c43e8d930bf215b83e2
Author: Qiang-Liu <[email protected]>
AuthorDate: Fri Aug 22 10:05:17 2025 +0800
Add map_index_template to MappedOperator (#54648)
---
airflow-core/src/airflow/models/mappedoperator.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/airflow-core/src/airflow/models/mappedoperator.py
b/airflow-core/src/airflow/models/mappedoperator.py
index 5e5fe9975fd..4b187153ffc 100644
--- a/airflow-core/src/airflow/models/mappedoperator.py
+++ b/airflow-core/src/airflow/models/mappedoperator.py
@@ -172,6 +172,10 @@ class MappedOperator(DAGNode):
def doc_md(self) -> str | None:
return self.partial_kwargs.get("doc_md")
+ @property
+ def map_index_template(self) -> str | None:
+ return self.partial_kwargs.get("map_index_template")
+
@property
def inherits_from_empty_operator(self) -> bool:
"""Implementing an empty Operator."""
