Skip to content

Commit 223dcac

Browse files
uranusjrferruzzi
authored andcommitted
Unconditionally disable start_from_trigger (apache#53744)
1 parent 7c050ba commit 223dcac

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,13 +72,18 @@ def expand_start_from_trigger(self, *, context: Context, session: Session) -> bo
7272
7373
:meta private:
7474
"""
75-
if not self.partial_kwargs.get("start_from_trigger", self.start_from_trigger):
75+
if self.partial_kwargs.get("start_from_trigger", self.start_from_trigger):
7676
log.warning(
7777
"Starting a mapped task from triggerer is currently unsupported",
7878
task_id=self.task_id,
7979
dag_id=self.dag_id,
8080
)
81-
return False
81+
82+
# This is intentional. start_from_trigger does not work correctly with
83+
# sdk-db separation yet, so it is disabled unconditionally for now.
84+
# TODO: TaskSDK: Implement this properly.
85+
return False
86+
8287
# start_from_trigger only makes sense when start_trigger_args exists.
8388
if not self.start_trigger_args:
8489
return False

0 commit comments

Comments
 (0)