From e839ae8d2958eeb901209844cdee15f915ddeb7d Mon Sep 17 00:00:00 2001 From: Tzu-ping Chung Date: Fri, 25 Jul 2025 17:27:35 +0800 Subject: [PATCH] [v3-0-test] Unconditionally disable start_from_trigger (#53744) (cherry picked from commit 61862eea2956b43793a984804db272dbc9aa8861) Co-authored-by: Tzu-ping Chung --- 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 205e8da16dd8d..b252b10477e0e 100644 --- a/airflow-core/src/airflow/models/mappedoperator.py +++ b/airflow-core/src/airflow/models/mappedoperator.py @@ -62,13 +62,18 @@ def expand_start_from_trigger(self, *, context: Context, session: Session) -> bo :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