From 4befca9a2cd7b0681e487d06a48f0a231cf757f4 Mon Sep 17 00:00:00 2001 From: Rahul Vats <43964496+vatsrahul1001@users.noreply.github.com> Date: Fri, 4 Jul 2025 17:50:05 +0530 Subject: [PATCH] [v3-0-test] Run trigger expansion logic only when ``start_from_trigger`` is True (#52861) (cherry picked from commit f20b7206bbd00931036f64536bb7b83515044d05) Co-authored-by: Rahul Vats <43964496+vatsrahul1001@users.noreply.github.com> closes: #52845 --- airflow-core/src/airflow/models/mappedoperator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow-core/src/airflow/models/mappedoperator.py b/airflow-core/src/airflow/models/mappedoperator.py index bc598ef0469a8..205e8da16dd8d 100644 --- a/airflow-core/src/airflow/models/mappedoperator.py +++ b/airflow-core/src/airflow/models/mappedoperator.py @@ -62,7 +62,7 @@ def expand_start_from_trigger(self, *, context: Context, session: Session) -> bo :meta private: """ - if self.partial_kwargs.get("start_from_trigger", self.start_from_trigger): + if not 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,