Muthu
03/20/2020, 11:52 AMsashank
03/20/2020, 2:43 PMexecute_pipeline
uses an ephemeral DagsterInstance
and doesn’t save anything to the run storage or event logs.
To get the default local instance, where all data is stored on the filesystem in $DAGSTER_HOME
, you can call DagsterInstance.get()
. We can pass this instance as an argument to execute_pipeline
.
execute_pipeline(hello_ceral_pipeline, instance=DagsterInstance.get())
sashank
03/20/2020, 2:44 PM$DAGSTER_HOME
set, you’ll see the runs in dagitsashank
03/20/2020, 2:44 PMMuthu
03/20/2020, 4:28 PM