tree 112c7c1bfa5ce36b28311eb67aa5faf988743235
parent 836ef42fc9eb1766450231e7ada4683bc601c21a
author Ephraim Anierobi <splendidzigy24@gmail.com> 1698871035 +0100
committer Ephraim Anierobi <splendidzigy24@gmail.com> 1698872651 +0100
gpgsig -----BEGIN PGP SIGNATURE-----
 
 iHUEABYKAB0WIQS9oZEc9zL8clyUp/4Ip9yRa47wgAUCZUK9SwAKCRAIp9yRa47w
 gPLSAQCgQkdxR/JBg98napNjkfpcHf4NkBZ3vLNu58DrZrcW9AD/aJ19a2Hx6D63
 iKnLMFhIfcMoPydPZ95KkUJwHkRmNQE=
 =i6eV
 -----END PGP SIGNATURE-----

Fix pre-mature evaluation of tasks in mapped task group (#34337)

* Fix pre-mature evaluation of tasks in mapped task group

Getting the relevant upstream indexes of a task instance in a mapped task group
should only be done when the task has expanded. If the task has not expanded yet,
we should return None so that the task can wait for the upstreams before trying
to run.
This issue is more noticeable when the trigger rule is ONE_FAILED because then,
the task instance is marked as SKIPPED.
This commit fixes this issue.
closes: https://github.com/apache/airflow/issues/34023

* fixup! Fix pre-mature evaluation of tasks in mapped task group

* fixup! fixup! Fix pre-mature evaluation of tasks in mapped task group

* fixup! fixup! fixup! Fix pre-mature evaluation of tasks in mapped task group

* Fix tests

(cherry picked from commit 69938fd163045d750b8c218500d79bc89858f9c1)