``` @asset def my_asset(): return "my_asset" ...
# ask-community
a
Copy code
@asset
def my_asset():
    return "my_asset"

@op
def write(csv_file):
    print(csv_file)
    return 'ok'


@graph_asset
def my_graph_asset():
    return write(my_asset.to_source_asset())

my_job = define_asset_job(name="my_job", selection="my_graph_asset")
I'm trying to define
my_job
but I'm getting following error in execution plan creation -
Copy code
dagster._core.errors.DagsterInvariantViolationError: In job 'my_job' op 'write', input csv_file must get a value either (a) from a dependency or (b) from the inputs section of its configuration.
Any tips on how do I pass
my_asset
to
write
op?
🤖 1
Never mind. I figured that it's possible to do it in a job, not graph.