Rahul Dave
01/30/2023, 2:35 PM@op(out={"bar_1": Out(), "bar_2": Out()})
def bar():
return 1, 2
@op
def baz(foo_2, bar_2):
return foo_2 + bar_2
@graph(out={"foo_asset": GraphOut(), "baz_asset": GraphOut()})
def my_graph():
bar_1, bar_2 = bar()
foo_1, foo_2 = foo(bar_1)
return {"foo_asset": foo_1, "baz_asset": baz(foo_2, bar_2)}
defs = Definitions(
assets=[AssetsDefinition.from_graph(my_graph, can_subset=True)],
jobs=[define_asset_job("graph_asset")],
)