AJ Floersch
01/05/2023, 4:12 PMgraph_assets = AssetsDefinition.from_graph(the_graph, partitions_def=DailyPartitionsDefinition(...), can_subset=True)
claire
01/05/2023, 5:43 PM@asset
s, you could get the partitioning structure you're hoping forRohil Badkundri
01/05/2023, 6:04 PMgraph_assets = AssetsDefinition.from_graph(
the_graph,
partitions_def=DailyPartitionsDefinition(...),
can_subset=True,
keys_by_output = {
"output1" : AssetKey("_output1"),
"output2" : AssetKey("_output2")
})
@op
def dummy_op(dummy_input):
return dummy_input
output1 = AssetsDefinition.from_op(dummy_op, keys_by_input = {"dummy_input" : AssetKey("_output1"}, partitions_def=...)
output2 = AssetsDefinition.from_op(dummy_op, keys_by_input = {"dummy_input" : AssetKey("_output2"}, partitions_def=...)
AJ Floersch
01/05/2023, 9:47 PM