Skip to content

Structure endpoint attach downstream asset to task level #51401

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged

Conversation

pierrejeambrun
Copy link
Member

@pierrejeambrun pierrejeambrun commented Jun 4, 2025

Closes: #49316

Add an additional look up to bind the assets to the relevant task based on the dag_model.task_outlet_asset_references

Before:

Screenshot 2025-06-04 at 16 26 13

After

Screenshot 2025-06-04 at 16 10 54
Screenshot 2025-06-04 at 16 12 24

@boring-cyborg boring-cyborg bot added the area:API Airflow's REST/HTTP API label Jun 4, 2025
@pierrejeambrun pierrejeambrun self-assigned this Jun 4, 2025
@pierrejeambrun pierrejeambrun added this to the Airflow 3.0.3 milestone Jun 4, 2025
@pierrejeambrun
Copy link
Member Author

We have the same issue with AssetAliases. I'll follow up with another PR to improve it too.

@pierrejeambrun pierrejeambrun force-pushed the 49316-attach-downstream-asset-to-tasks branch from cf3d7b6 to 6231b36 Compare June 4, 2025 14:58
@pierrejeambrun pierrejeambrun changed the title 49316 attach downstream asset to tasks Structure endpoint attach downstream asset to task level Jun 5, 2025
@pierrejeambrun pierrejeambrun added the backport-to-v3-0-test Mark PR with this label to backport to v3-0-test branch label Jun 5, 2025
@pierrejeambrun pierrejeambrun merged commit 14ee1f4 into apache:main Jun 5, 2025
99 checks passed
@pierrejeambrun pierrejeambrun deleted the 49316-attach-downstream-asset-to-tasks branch June 5, 2025 09:29
github-actions bot pushed a commit that referenced this pull request Jun 5, 2025
…51401)

* Attach downstream assets to task

* Adjust tests
(cherry picked from commit 14ee1f4)

Co-authored-by: Pierre Jeambrun <[email protected]>
Copy link

github-actions bot commented Jun 5, 2025

Backport successfully created: v3-0-test

Status Branch Result
v3-0-test PR Link

github-actions bot pushed a commit to aws-mwaa/upstream-to-airflow that referenced this pull request Jun 5, 2025
…pache#51401)

* Attach downstream assets to task

* Adjust tests
(cherry picked from commit 14ee1f4)

Co-authored-by: Pierre Jeambrun <[email protected]>
pierrejeambrun added a commit that referenced this pull request Jun 5, 2025
…51401) (#51425)

* Attach downstream assets to task

* Adjust tests
(cherry picked from commit 14ee1f4)

Co-authored-by: Pierre Jeambrun <[email protected]>
kaxil pushed a commit that referenced this pull request Jun 6, 2025
…51401) (#51425)

* Attach downstream assets to task

* Adjust tests
(cherry picked from commit 14ee1f4)

Co-authored-by: Pierre Jeambrun <[email protected]>
kaxil pushed a commit that referenced this pull request Jun 6, 2025
…51401) (#51425)

* Attach downstream assets to task

* Adjust tests
(cherry picked from commit 14ee1f4)

Co-authored-by: Pierre Jeambrun <[email protected]>
sanederchik pushed a commit to sanederchik/airflow that referenced this pull request Jun 7, 2025
* Attach downstream assets to task

* Adjust tests
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area:API Airflow's REST/HTTP API backport-to-v3-0-test Mark PR with this label to backport to v3-0-test branch
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Assets updated by a dag are attached to the last task in a dag graph rather than the task that creates the update
2 participants