Hey all! In order to support changes to the Dagster code involving changes in the tables schema (we're using Snowflake) I want to create an op (or whatever that is needed) to initialize the target schema (i.e. create a new tmp_schema and work inside it). I'm looking for a way to run this initialization operation before each job. Right now our jobs are defined using the template:

one_job = define_asset_job(
    name="one_job",
    selection=AssetSelection.keys("some_asset").upstream()
)

is there a way to define before each job something like that? Thanks!

Hi Amit - there currently isn't an easy way to do this. The most common way is to have the code inside the assets create the schema if it doesn't already exist. An alternative would be to use a graph-backed asset

Thanks! I'll take a look into that