Justin Swaney
03/18/2020, 3:13 PMfilesystem
, everything works great. When I use the Python API and pass the YAML config like dagster pipeline execute -f dask_hello_world.py -n dask_pipeline -e dask_hello_world.yaml
, I get a PIPELINE_INIT_FAILURE
error.dask_pipeline - dbd1d007-38b9-4d20-a49e-bb196edf0e10 - PIPELINE_INIT_FAILURE - Pipeline failure during initialization of pipeline "dask_pipeline". This may be due to a failure in initializing a resource or logger.
event_specific_data = {"error": ["dagster.core.errors.DagsterUnmetExecutorRequirementsError: You have attempted to use an executor that uses multiple processes with an ephemeral DagsterInstance. A non-ephemeral instance is needed to coordinate execution between multiple processes.
alex
03/18/2020, 3:38 PM$DAGSTER_HOME
dagit
because we create a temporary directory based DagsterInstance
for you if DAGSTER_HOME
is not setJustin Swaney
03/18/2020, 6:40 PM$DAGSTER_HOME
in the error now that you mention it:
You can configure your default instance via $DAGSTER_HOME or ensure a valid one is passed when invoking the python APIs.
dagit
. Thanks for the explanation!