uranusjr commented on code in PR #59691:
URL: https://github.com/apache/airflow/pull/59691#discussion_r3257243398
##########
airflow-core/src/airflow/models/taskinstance.py:
##########
@@ -2293,6 +2293,14 @@ def tg2(inp):
# and "ti_count == ancestor_ti_count" does not work, since the further
# expansion may be of length 1.
if not _is_further_mapped_inside(relative, common_ancestor):
+ placeholder_index = _resolve_placeholder_map_index(
+ task=task, relative=relative, map_index=ancestor_map_index,
run_id=run_id, session=session
+ )
+ # Handle cases where an upstream mapped placeholder (map_index = -1)
has already
+ # been expanded and replaced by its successor (map_index = 0) at
evaluation time.
Review Comment:
Comments are needed here to describe what causes the “cases” to happen, not
just the final outcome.
--
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]
