Lee-W commented on code in PR #53696:
URL: https://github.com/apache/airflow/pull/53696#discussion_r2241779248
##########
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:
got it. makes sense
--
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]
