Skip to content

Fix logic of the skip_all_except method#31153

Merged
eladkal merged 7 commits into
apache:mainfrom
dzhigimont:fix_branch_operator_for_mapped_tasks
Jul 6, 2023
Merged

Fix logic of the skip_all_except method#31153
eladkal merged 7 commits into
apache:mainfrom
dzhigimont:fix_branch_operator_for_mapped_tasks

Conversation

@dzhigimont

Copy link
Copy Markdown
Contributor

Fix logic of the skip_all_except method to work correctly with a mapped branch operator.
Closes: #30883

@dzhigimont
dzhigimont requested review from XD-DENG, ashb and kaxil as code owners May 9, 2023 13:27
@dzhigimont
dzhigimont force-pushed the fix_branch_operator_for_mapped_tasks branch 2 times, most recently from 473d6bd to 9bfe60c Compare May 9, 2023 18:57
Comment thread airflow/models/skipmixin.py Outdated
@dzhigimont
dzhigimont force-pushed the fix_branch_operator_for_mapped_tasks branch 2 times, most recently from e59e648 to 949733e Compare May 11, 2023 16:51
Comment thread airflow/models/skipmixin.py Outdated
@uranusjr

Copy link
Copy Markdown
Member

Also a test on the bug this should fix would be preferred.

@dzhigimont
dzhigimont force-pushed the fix_branch_operator_for_mapped_tasks branch from 949733e to 33ef635 Compare June 9, 2023 07:04
@dzhigimont

Copy link
Copy Markdown
Contributor Author

Also a test on the bug this should fix would be preferred.

I've added the appropriate test case

@dzhigimont
dzhigimont force-pushed the fix_branch_operator_for_mapped_tasks branch 2 times, most recently from 86b4176 to a6f7a83 Compare June 9, 2023 11:20
@eladkal eladkal added this to the Airlfow 2.6.3 milestone Jun 9, 2023
@eladkal eladkal added the type:bug-fix Changelog: Bug Fixes label Jun 9, 2023
@dzhigimont
dzhigimont force-pushed the fix_branch_operator_for_mapped_tasks branch from a6f7a83 to 73bc921 Compare June 13, 2023 10:21
Comment thread airflow/models/skipmixin.py Outdated
Comment thread airflow/models/skipmixin.py Outdated
@dzhigimont
dzhigimont force-pushed the fix_branch_operator_for_mapped_tasks branch from e79ceaa to aaa1bb9 Compare June 14, 2023 07:27
Comment thread airflow/models/skipmixin.py Outdated
@eladkal

eladkal commented Jul 6, 2023

Copy link
Copy Markdown
Contributor

rebasing after #32405 is merged should solve the failing test

@potiuk
potiuk force-pushed the fix_branch_operator_for_mapped_tasks branch from 8543f62 to 2888976 Compare July 6, 2023 14:43
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.

BranchPythonOperator skips downstream tasks for all mapped instances in TaskGroup mapping

4 participants