github-actions[bot] opened a new pull request, #67704: URL: https://github.com/apache/airflow/pull/67704
A task using a "fast triggered" trigger rule (ONE_FAILED, ONE_SUCCESS, ONE_DONE) inside a mapped task group was evaluated against every expanded instance of its upstream, instead of the upstream instance sharing its own map index. As a result a single failed (or succeeded) upstream instance wrongly triggered the rule for every expanded instance of the task — e.g. a mapped ONE_FAILED reporting task ran for all map indexes when only one upstream had failed. The broad "depend on every upstream instance" behavior is only needed for the not-yet-expanded summary task instance (map_index < 0), so a fast trigger rule does not prematurely skip the task before the mapped task group expands (the case fixed in #34023). Restrict that special case to the summary instance; expanded instances now use the normal per-map-index upstream resolution. (cherry picked from commit 862b647facf4d6df67c63218257fd0dcbe11c315) Co-authored-by: Shahar Epstein <[email protected]> closes: #50210 -- 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]
