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())
$DAGSTER_HOME
set, you’ll see the runs in dagitMuthu
03/20/2020, 4:28 PM