Ahmed-Khaled-CS opened a new issue, #35541: URL: https://github.com/apache/airflow/issues/35541
### Apache Airflow version 2.7.3 ### What happened Hello folks, I have a use case that doesn't work anymore after the release of the new version 2.7.3. I have done some investigation and found that is related to this [PR](https://github.com/apache/airflow/pull/34337) as I have reverted this locally and run some tests it worked as expected. Please find below how to reproduce the issue. Cc @ephraimbuddy Thanks. ### What you think should happen instead _No response_ ### How to reproduce Below is the DAG code: ``` def dag(): @task def make_list(): return [4, 42, 2] @task def double(n): if n == 42: raise AirflowSkipException("42") return n*2 @task def last(n): print(n) @task_group def group(n: int) -> None: last(double(n)) list = make_list() group.expand(n=list) dag() ``` Running this DAG with the 2.7.3 version, will give you the result below: <img width="1058" alt="Screenshot 2023-11-08 at 22 58 07" src="https://github.com/apache/airflow/assets/114393790/f2199d4d-f283-485e-8860-f53b0db29e3f";> <img width="2160" alt="Screenshot 2023-11-08 at 22 58 22" src="https://github.com/apache/airflow/assets/114393790/8c84335f-eb9e-4829-b679-55d84da21625";> <img width="2160" alt="Screenshot 2023-11-08 at 22 58 30" src="https://github.com/apache/airflow/assets/114393790/df5eeeef-08f6-474b-8944-8a53bd2e30a1";> As you can see, the status of the last task is skipped and the map index 0 and 1 was not launched. You will obtain the same issue with AirflowFailException instead of AirflowSkipException and the status of the last task will be failed. In the other hand, if you run the same DAG with the 2.7.2 version (or without the changes in the provided PR above), you will get the result below which is the correct one: <img width="843" alt="Screenshot 2023-11-08 at 22 53 06" src="https://github.com/apache/airflow/assets/114393790/d518dfde-81eb-4a45-81f9-9bba3a57b3da";> <img width="2116" alt="Screenshot 2023-11-08 at 22 53 31" src="https://github.com/apache/airflow/assets/114393790/8686c7bd-9803-4ab5-934f-ce4560c4de7a";> <img width="2116" alt="Screenshot 2023-11-08 at 22 53 40" src="https://github.com/apache/airflow/assets/114393790/ff6448b3-a63e-40fe-8f71-41ab6571998c";> ### Operating System linux ### Versions of Apache Airflow Providers _No response_ ### Deployment Docker-Compose ### Deployment details [Airflow Breeze](https://github.com/apache/airflow/blob/main/BREEZE.rst#id13) ### Anything else _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md) -- 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]
