Skip to content

Commit 7c331e6

Browse files
committed
only log warning if it's enabled
1 parent 91230b3 commit 7c331e6

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

airflow/models/mappedoperator.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -60,11 +60,12 @@ def expand_start_from_trigger(self, *, context: Context, session: Session) -> bo
6060
6161
:meta private:
6262
"""
63-
log.warning(
64-
"Starting a mapped task from triggerer is currently unsupported",
65-
task_id=self.task_id,
66-
dag_id=self.dag_id,
67-
)
63+
if self.partial_kwargs.get("start_from_trigger", self.start_from_trigger):
64+
log.warning(
65+
"Starting a mapped task from triggerer is currently unsupported",
66+
task_id=self.task_id,
67+
dag_id=self.dag_id,
68+
)
6869
return False
6970
# start_from_trigger only makes sense when start_trigger_args exists.
7071
if not self.start_trigger_args:

0 commit comments

Comments
 (0)