SameerMesiah97 commented on code in PR #59691:
URL: https://github.com/apache/airflow/pull/59691#discussion_r3269794345
##########
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:
Agreed. The comment has been expanded. Please see the below:
```
# During mapped task group expansion, upstream placeholder task instances
# (map_index = -1) may already have been replaced by their first expanded
# successor (map_index = 0) while downstream task instances are still
# unexpanded and continue resolving dependencies against the placeholder
index.
```
--
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]
