Skip to content

Commit e19e8d3

Browse files
dstandishshubham-pyc
authored andcommitted
Disable starting a mapped task from trigger (apache#48006)
The scheduler versions of "ExpandInput" classes don't have a "resolve" method anymore so scheduler crashes when trying to expand_start_from_trigger. To keep the scheduler running, for now we disable the feature. Related to apache#47735 May be fixed in apache#48009
1 parent 90db1cc commit e19e8d3

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
from typing import TYPE_CHECKING
2121

2222
import attrs
23+
import structlog
2324

2425
from airflow.models.abstractoperator import AbstractOperator
2526
from airflow.sdk.definitions.mappedoperator import MappedOperator as TaskSDKMappedOperator
@@ -31,6 +32,8 @@
3132

3233
from airflow.sdk.definitions.context import Context
3334

35+
log = structlog.get_logger()
36+
3437

3538
@attrs.define(
3639
kw_only=True,
@@ -57,6 +60,13 @@ def expand_start_from_trigger(self, *, context: Context, session: Session) -> bo
5760
5861
:meta private:
5962
"""
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+
)
69+
return False
6070
# start_from_trigger only makes sense when start_trigger_args exists.
6171
if not self.start_trigger_args:
6272
return False

0 commit comments

Comments
 (0)