matthieuauger commented on issue #54779:
URL: https://github.com/apache/airflow/issues/54779#issuecomment-3353662574
Hello,
I think the initial issue is related to "Downstream" related tasks and
depth-first workflows.
Use case is when you have multiple mapped tasks in a workflow, for example
in a group.
My personal is use case is that I download data for each of my users with
mapped tasks.
My DAG looks like this
- TaskGroup (mapped to 10 users)
- Task 1 : create_job (mapped to 10 users with the group)
- Task 2 : download_data (mapped to 10 users with the group)
- Task 3 : validate_data (mapped to 10 users with the group)
Let's assume everything went well for 9 out of 10 users (index 0 to 8) but
failed for last user (mapped task index 9).
I would like to be able to restart task instance create_job[9], click
downstream and only see download_data[9] and validate_date[9].
This is really useful because currently if a mapped task fails, you need to
re-run everything.
I tried again with new version but issue still persist
<img width="1228" height="663" alt="Image"
src="https://github.com/user-attachments/assets/11b6109b-bab2-44bf-acd4-54b7aeb165ce";
/>
--
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]
