https://dagster.io/ logo
Title
s

Sanat Mouli

03/03/2022, 7:36 AM
Hi There, is it possible to schedule a Software-Defined Asset in Dagster? In the same way we can schedule a dagster job, like with this
@schedule(
    cron_schedule="45 6 * * *",
    job=hello_cereal_job,
    execution_timezone="US/Central",
)
c

chris

03/03/2022, 5:55 PM
Yes - you can create a job from your assets, which can then be passed to a schedule.
from dagster import asset, AssetGroup, schedule

@asset
def the_asset():
    ...

@schedule(AssetGroup(assets=[the_asset]).build_job())
def the_schedule():
    ...
s

Sanat Mouli

03/04/2022, 6:37 AM
Thanks!!
Also, can we have an asset return an output to an op and then have that op return an output back to an asset?