Michael Dombrowski
12/01/2022, 1:25 PMfrom dagster import AssetKey, SourceAsset, asset, repository
@asset
def repository_a_asset():
return 5
@repository
def repository_a():
return [repository_a_asset]
repository_a_source_asset = SourceAsset(key=AssetKey("repository_a_asset"))
@asset
def repository_b_asset(repository_a_asset):
return repository_a_asset + 6
@repository
def repository_b():
return [repository_b_asset, repository_a_asset]
nickvazz
12/01/2022, 5:57 PMchris
12/02/2022, 6:15 PMrepository_a_asset
in both repos, instead of repository_a_source_asset
in the latter