uranusjr commented on code in PR #53696:
URL: https://github.com/apache/airflow/pull/53696#discussion_r2239752062
##########
airflow-core/src/airflow/models/taskmap.py:
##########
@@ -131,14 +131,14 @@ def expand_mapped_task(cls, task, run_id: str, *,
session: Session) -> tuple[Seq
order by map index, and the maximum map index value.
"""
from airflow.models.expandinput import NotFullyPopulated
- from airflow.models.mappedoperator import get_mapped_ti_count
+ from airflow.models.mappedoperator import MappedOperator as
DbMappedOperator, get_mapped_ti_count
Review Comment:
The ultimate goal is to not import `airflow.sdk` classes in core (except in
`airflow.serialization`, which needs to understand both), and not import
`airflow.models.MappedOperator` and `SerializedBaseOperator` in sdk, so these
are mostly temporary measures.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
