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 61862eea295 Unconditionally disable start_from_trigger (#53744)
61862eea295 is described below
commit 61862eea2956b43793a984804db272dbc9aa8861
Author: Tzu-ping Chung <[email protected]>
AuthorDate: Fri Jul 25 17:27:35 2025 +0800
Unconditionally disable start_from_trigger (#53744)
---
airflow-core/src/airflow/models/mappedoperator.py | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/models/mappedoperator.py
b/airflow-core/src/airflow/models/mappedoperator.py
index ec3ec96a218..5b309ffb838 100644
--- a/airflow-core/src/airflow/models/mappedoperator.py
+++ b/airflow-core/src/airflow/models/mappedoperator.py
@@ -72,13 +72,18 @@ class MappedOperator(TaskSDKMappedOperator):
:meta private:
"""
- if not self.partial_kwargs.get("start_from_trigger",
self.start_from_trigger):
+ if self.partial_kwargs.get("start_from_trigger",
self.start_from_trigger):
log.warning(
"Starting a mapped task from triggerer is currently
unsupported",
task_id=self.task_id,
dag_id=self.dag_id,
)
- return False
+
+ # This is intentional. start_from_trigger does not work correctly with
+ # sdk-db separation yet, so it is disabled unconditionally for now.
+ # TODO: TaskSDK: Implement this properly.
+ return False
+
# start_from_trigger only makes sense when start_trigger_args exists.
if not self.start_trigger_args:
return False
