Skip to content

Commit f20b720

Browse files
Run trigger expansion logic only when start_from_trigger is True (#52861)
closes :#52845
1 parent 4e6b7f8 commit f20b720

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airflow-core/src/airflow/models/mappedoperator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ def expand_start_from_trigger(self, *, context: Context, session: Session) -> bo
6262
6363
:meta private:
6464
"""
65-
if self.partial_kwargs.get("start_from_trigger", self.start_from_trigger):
65+
if not self.partial_kwargs.get("start_from_trigger", self.start_from_trigger):
6666
log.warning(
6767
"Starting a mapped task from triggerer is currently unsupported",
6868
task_id=self.task_id,

0 commit comments

Comments
 (0)