gvergnolle opened a new issue, #57101:
URL: https://github.com/apache/airflow/issues/57101
### Apache Airflow version
3.1.0
### If "Other Airflow 2/3 version" selected, which one?
_No response_
### What happened?
When marking a mapped task as success/failed within an expanded task group,
all other mapped tasks were also updated to the same status.
### What you think should happen instead?
Changing the state of a single mapped task should not propagate to other
task dynamically created by `expand`.
### How to reproduce
- Import the following DAG in your environment:
```[python]
from datetime import datetime
from airflow.sdk import task, task_group, DAG
with DAG(
dag_id="test_dag",
schedule=None,
start_date=datetime(2023, 11, 3),
) as dag:
globals()["test_dag"] = dag
@task_group()
def create_simple_tasks(number: int):
@task(task_id="task_1")
def task_1(number: int):
return number + 1
@task(task_id="task_2")
def task_2(number: int):
return number + 2
task_1(number) >> task_2(number)
create_simple_tasks.expand(number=[1, 2, 3])
```
- Manually trigger a run
- Set a mapped task to success/fail like the picture below (make sure to
unselect "Downstream")
<img width="1728" height="968" alt="Image"
src="https://github.com/user-attachments/assets/7506e305-1570-48d1-9a0d-103f2390560b";
/>
<img width="897" height="452" alt="Image"
src="https://github.com/user-attachments/assets/0f4b8708-8674-4c01-a20f-e76d1507807e";
/>
- All the other mapped tasks have been marked as `Failed` as well
<img width="1728" height="966" alt="Image"
src="https://github.com/user-attachments/assets/c5e8dae6-af0d-4fdc-9974-fa13df0fc7b1";
/>
### Operating System
Debian GNU/Linux 12 (bookworm)
### Versions of Apache Airflow Providers
apache-airflow-providers-standard==1.8.0
### Deployment
Docker-Compose
### Deployment details
_No response_
### 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]
