You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ur...@apache.org on 2025/08/22 02:05:25 UTC
(airflow) branch main updated: Add map_index_template to MappedOperator (#54648)
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 <li...@gmail.com>
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."""