Skip to content

Conversation

@hussein-awala
Copy link
Member

@hussein-awala hussein-awala commented Mar 13, 2023

closes: #30073


To calculate ancestor_map_index, we divide map_index * ancestor_ti_count by ti_count which can be zero when we expand a task group and we provide an empty list as argument, in this case the scheduler enter in a crush loop.

In this PR I add a check for 0 value and a test to check if the TriggerRuleDep works with empty expended lists.

@potiuk potiuk force-pushed the fix/trigger_rule_with_none_mapped_tasks branch from 9f638b8 to c529bf1 Compare March 14, 2023 07:02
@hussein-awala hussein-awala requested a review from uranusjr March 14, 2023 22:39
@eladkal eladkal added this to the Airflow 2.5.3 milestone Mar 15, 2023
@potiuk potiuk merged commit 8d22828 into apache:main Mar 15, 2023
@pierrejeambrun pierrejeambrun added the type:bug-fix Changelog: Bug Fixes label Mar 22, 2023
pierrejeambrun pushed a commit that referenced this pull request Mar 23, 2023
* Fix TriggerRuleDep when the mapped tasks count is 0

* merge the two checks in a simple one

(cherry picked from commit 8d22828)
pierrejeambrun pushed a commit that referenced this pull request Mar 24, 2023
* Fix TriggerRuleDep when the mapped tasks count is 0

* merge the two checks in a simple one

(cherry picked from commit 8d22828)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

type:bug-fix Changelog: Bug Fixes

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Task group expand fails on empty list at get_relevant_upstream_map_indexes

5 participants