George Pearse
06/22/2022, 4:57 PMfrom dagster import AssetKey, SourceAsset, asset, repository, with_resources
from pipelines.datastores.MongoHandler import mongo_handler_resource
# imagine it's just an int
ml_cxr_asset = SourceAsset(key=AssetKey("ml_cxr_asset"))
@asset
def repository_a_asset(ml_cxr_asset):
return ml_cxr_asset + 5
@asset
def repository_b_asset(repository_a_asset):
return repository_a_asset + 6
@asset(required_resource_keys={'test_resource'})
def repository_c_asset(context, repository_b_asset):
test = context.test_resource
return repository_b_asset + 6
asset_configured = with_resources(
[repository_c_asset], resource_defs={'test_resource': mongo_handler_resource}
)
@repository
def repository_c():
return asset_configured + [ml_cxr_asset, repository_b_asset, repository_a_asset]
When I click on repository_c_asset lineage, I don't see ml_cxr_asset, but when I click on repository_b_asset lineage I do. Seems odd to me.sandy
06/23/2022, 12:40 AMGeorge Pearse
06/23/2022, 9:20 AMjosh
06/23/2022, 3:55 PM