Commits on Sep 20, 2022

1. Fix deadlock when mapped task with removed upstream is rerun …

   When a dag with a mapped downstream tasks that depends on a mapped upstream tasks that have some mapped indexes
   removed is rerun, we run into a deadlock because the trigger rules evaluation is not accounting for removed
   task instances.
   
   The fix for the deadlocks was to account for the removed task instances where possible in the trigger rules
   
   In this fix, I added a case where if we set flag_upstream_failed, then for the removed task instance, the downstream of that task instance will be removed. That's if the upstream with index 3 is removed, then downstream
   with index 3 will also be removed if flag_upstream_failed is set to True.

   

   ephraimbuddy committed Sep 20, 2022
   Configuration menu

   • View commit details
   • Copy full SHA for 8030bc1
   • Browse repository at this point

   Copy the full SHA

   8030bc1 View commit details

   Browse the repository at this point in the history

2. Fixup tests in taskinstance.py

   

   ephraimbuddy committed Sep 20, 2022
   Configuration menu

   • View commit details
   • Copy full SHA for eed077a
   • Browse repository at this point

   Copy the full SHA

   eed077a View commit details

   Browse the repository at this point in the history

3. Add test for mapped task dependencies check including removed task in… …

   … test_taskinstance.py

   

   ephraimbuddy committed Sep 20, 2022
   Configuration menu

   • View commit details
   • Copy full SHA for 2584bcb
   • Browse repository at this point

   Copy the full SHA

   2584bcb View commit details

   Browse the repository at this point in the history