Rahul Dave
01/30/2023, 2:36 PMVinnie
01/30/2023, 2:44 PM"graph_asset"
would just be the name scoped to the job created by define_asset_job()
. You could pass any other string to it.Rahul Dave
01/30/2023, 2:53 PMRahul Dave
01/30/2023, 2:54 PMRahul Dave
01/30/2023, 2:54 PMVinnie
01/30/2023, 2:58 PMmy_asset = AssetsDefinition.from_graph(my_graph, keys_by_output_name={"result": AssetKey("my_asset")})
my_job = define_asset_job("my_job", selection=["my_asset"])
my_other_asset = AssetsDefinition.from_graph(my_other_graph, keys_by_output_name={"result": AssetKey("my_other_asset"))
my_other_job = define_asset_job("my_other_job", selection=["my_other_asset"])
defs = Definitions(
assets=[my_asset, my_other_asset],
jobs=[my_job, my_other_job],
)
Rahul Dave
01/30/2023, 3:06 PMVinnie
01/30/2023, 3:07 PMRahul Dave
01/30/2023, 3:07 PMjamie
01/30/2023, 4:07 PMdefine_asset_job
it will create a job that will materialize all of the assets in your definition. So you could in theory have jobs for each asset by providing the selection
parameter and then one encompassing job that can materialize every single asset