eladkal commented on a change in pull request #20411:
URL: https://github.com/apache/airflow/pull/20411#discussion_r772478077
##########
File path: airflow/models/skipmixin.py
##########
@@ -140,6 +140,8 @@ def skip_all_except(self, ti: TaskInstance,
branch_task_ids: Union[str, Iterable
self.log.info("Following branch %s", branch_task_ids)
if isinstance(branch_task_ids, str):
branch_task_ids = {branch_task_ids}
+ elif branch_task_ids is None:
+ branch_task_ids = {}
Review comment:
see https://github.com/apache/airflow/issues/18454 and
https://github.com/apache/airflow/pull/18471
If we now we are handling None then we need also to change
https://github.com/apache/airflow/blob/9b05f027c3411ff5a5fec71ccf6826207ff9016d/airflow/operators/python.py#L221
--
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]
