How to provide deps to graph_assets?

[clairelin135]

Currently, graph_assets do not contain a deps argument, how can I provide deps?

[clairelin135]

Here's an example:

from dagster import graph_asset, asset, AssetIn, op, Nothing, In


@asset
def upstream():
    ...


@op(ins={"upstream": In(Nothing)})
def my_op():
    return ...


@graph_asset(
    ins={"upstream": AssetIn(dagster_type=Nothing)},
)
def my_graph_asset(upstream):
    return my_op(upstream)

[andrejakobsen]

Thanks! Would it be useful to create a PR that adds the deps argument to graph_asset? In which case, I suppose one should also add it to op. I can definitely take a look unless there is a good reason why it isn't implemented yet.

[sryza]

If you're looking to construct a set of deps programmatically instead of hardcoding a set of arguments to your function, you can do something like this:

from typing import Sequence

from dagster import AssetIn, AssetKey, In, Nothing, graph_asset, materialize, op

deps = [AssetKey("a"), AssetKey("b")]

@op(ins={dep.to_python_identifier(): In(Nothing) for dep in deps})
def inner(**kwargs):
    pass

@graph_asset(ins={dep.to_python_identifier(): AssetIn(dep) for dep in deps})
def my_graph_asset(**kwargs):
    return inner(**kwargs)