Neil
04/12/2023, 8:30 PMgraph_multi_asset
to feed the same output to different downstream assets. However, in Dagit it only shows one of the outputs and the other disappears since, I suppose, it's the same object being repeated twice. How can I make this one asset be upstream of two different assets with different key_prefixes?
@op
def give_1():
return 1
@graph_multi_asset(
outs={
"first": AssetOut(key_prefix=["test", "a"]),
"second": AssetOut(key_prefix=["test", "b"])
}
)
def test_multi_asset_simple():
output = give_1()
output2 = output
return {"first": output, "second": output2}
Neil
04/12/2023, 8:33 PMNeil
04/12/2023, 8:34 PMclaire
04/13/2023, 8:49 PM@op
def noop(give_1):
return give_1
@graph_multi_asset(
outs={"first": AssetOut(key_prefix=["test", "a"]), "second": AssetOut(key_prefix=["test", "b"])}
)
def test_multi_asset_simple():
output = give_1()
return {"first": output, "second": noop(output)}
Then you'll be able to see two assets as desiredNeil
04/13/2023, 11:22 PM