19913d85-f662-4518-a9a1-7adc1793dfd4.png){kind=small}
Does calling an `@asset` function from a `@job` ca...
# ask-communityg
Gabe Schine
12/21/2022, 6:28 PMDoes calling an
@asset@job🤖 1
Gabe Schine
12/21/2022, 6:30 PM@Dagster Jarred I've had trouble finding a definitive answer to this question in the documentation.
Gabe Schine
12/21/2022, 7:57 PMDoing my own testing, it appears that answer is "yes", it will re-materialize the asset?
Gabe Schine
12/21/2022, 7:59 PMIn which case: let's say I want a job to run whenever one of the input assets is re-materialized, but I want to use whatever was the latest value for all of the assets, is there a way to do that?
d
Daniel Mosesson
12/21/2022, 9:43 PMWhy not use the
asset_sensorg
Gabe Schine
12/21/2022, 9:58 PMI am for triggering the job in response to the asset being updated by a
FreshnessPolicyGabe Schine
12/21/2022, 9:58 PMIs there something in the use of
asset_sensorGabe Schine
12/21/2022, 10:02 PMExample:
Copy code
@asset(freshness_policy=...)
def my_asset(): return 5
@job(...)
def use_my_asset():
# This is where I'd like to load the value from the last materialization.
asset_value = my_asset()
do_stuff_with_value(asset_value)Gabe Schine
12/21/2022, 10:04 PMI have an
asset_reconciliation_sensormy_asset@asset_sensoruse_my_assetd
Dagster Jarred
12/22/2022, 4:23 AMthanks @Gabe Schine for pointing out this question. I’ll have to defer to one of our experts @sandy @owen @sean
g
Gabe Schine
12/22/2022, 5:39 AMHey - thanks @Dagster Jarred for looping back around.
s
sandy
12/22/2022, 6:39 AMHi Gabe, we don't currently have a straightforward way to use an asset as an input to one of the ops in a job, although we're interested in adding this. Here's the issue where we've been tracking this: https://github.com/dagster-io/dagster/issues/10874
g
Gabe Schine
12/22/2022, 6:43 AMGotcha thanks for the link! For now I guess I should model the downstream job as another asset to take advantage of the input handling there.
43 Views