Yang
12/12/2022, 11:54 PMg_pillar_name = SourceAsset(
key=AssetKey("g_pillar_name"),
io_manager_key="pillar_name_io",
metadata={"pillar_name": "governance"})
Then in the io_manager I would reference it
context.metadata.get("pillar_name")
Does this not work? I swear it worked before. Thanks!g_metrics = AssetsDefinition.from_graph(
pillar_metrics_scores,
keys_by_input_name={
"pillar_name": AssetKey("g_pillar_name")},
keys_by_output_name={
"result": AssetKey("g_metrics_scores")},
partitions_def=year_dataset_context_def)
sandy
12/13/2022, 12:31 AMload_input
function? what version are you on?Yang
12/13/2022, 1:03 AMsandy
12/13/2022, 5:34 PMcontext.upstream_output.metadata.get("pillar_name")
context.metadata
will return metadata that you put on the AssetIn
, not metadata from the upstreamYang
12/13/2022, 5:54 PM