https://dagster.io/ logo
#ask-community
Title
# ask-community
r

Rahul Dave

01/30/2023, 2:35 PM
Copy code
@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")],
)