Qwame
02/13/2023, 5:55 PMexecute_in_process
method on a job created using define_asset_job
?owen
02/13/2023, 6:17 PMdefine_asset_job
jobs aren't fully resolved until they're placed there. So one option would look like
from my_package import my_repository
def test_my_job():
result = my_repository.get_job("name_of_job").execute_in_process()
Qwame
02/13/2023, 6:18 PMQwame
02/13/2023, 6:23 PMSaul Burgos
02/17/2023, 5:21 PMowen
02/17/2023, 5:30 PMowen
02/17/2023, 5:31 PMdagster.yaml
file set up, then you can pass in instance=DagsterInstance.get()
to the execute_in_process call, which should cause this execution to write to your real dagster instance (rather than the default temporary one)Saul Burgos
02/17/2023, 8:01 PMDAGSTER_HOME
is set but dagster.yaml
isn't present or is empty, Dagster will persist data on the local filesystem, structured like the following:"
But when I run the job I am getting Dagster home is not setSaul Burgos
02/17/2023, 8:03 PMSaul Burgos
02/17/2023, 9:58 PM