Gustavo Carvalho
06/03/2023, 2:22 PMRunRequest
instance directly from python?Zach
06/03/2023, 2:50 PMRunRequest
outside of a running Dagster instance, because the Dagster instance needs to be able to pick up the RunRequest
event and execute it for you. You can use job_name.execute_in_process()
or execute_job instead if either of those fit your needs.Abhishek Agrawal
06/03/2023, 2:50 PMGustavo Carvalho
06/03/2023, 2:56 PMexecute_job
will do.
My use case is testing a single run materialization for a partition range. This can be done by setting the tags argument:
execute_job(
...,
tags={
"dagster/asset_partition_range_start": start_partition_key,
"dagster/asset_partition_range_end": end_partition_key,
}
)
Gustavo Carvalho
06/03/2023, 2:59 PMtest_orders_multi_partition_backfill
claire
06/07/2023, 4:30 PMexecute_in_process
with the provided tags like in the code snippet you linked