From b8edb7f1903371a44e0819da169009bf6ab55456 Mon Sep 17 00:00:00 2001 From: Tzu-ping Chung Date: Fri, 25 Jul 2025 14:29:55 +0800 Subject: [PATCH] Unconditionally disable start_from_trigger --- 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 ec3ec96a218b9..5b309ffb83864 100644 --- a/airflow-core/src/airflow/models/mappedoperator.py +++ b/airflow-core/src/airflow/models/mappedoperator.py @@ -72,13 +72,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