Skip to content

Commit

Permalink
fix naming
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Jan 17, 2024
1 parent d74d26d commit e1a4076
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -437,7 +437,7 @@ def upstream(context: AssetExecutionContext):

@asset
def downstream(context: AssetExecutionContext, upstream):
mat = context.latest_materialization_event("upstream")
mat = context.latest_materialization_for_upstream_asset("upstream")
assert mat is not None
assert mat.metadata["foo"].value == "bar"

Expand All @@ -452,7 +452,7 @@ def upstream():

@asset
def downstream(context: AssetExecutionContext, upstream):
mat = context.latest_materialization_event("upstream")
mat = context.latest_materialization_for_upstream_asset("upstream")
assert mat is not None
assert mat.metadata["foo"].value == "bar"

Expand Down

0 comments on commit e1a4076

Please sign in to comment.