Changeset View
Changeset View
Standalone View
Standalone View
docs/content/deployment/guides/dask.mdx
Show All 20 Lines | |||||
It is relatively straightforward to set up and run a Dagster pipeline on local Dask. This can be useful for test. | It is relatively straightforward to set up and run a Dagster pipeline on local Dask. This can be useful for test. | ||||
First, run `pip install dagster-dask`. | First, run `pip install dagster-dask`. | ||||
Then, you'll need to add the dask executor to a **`ModeDefinition`** on your pipeline: | Then, you'll need to add the dask executor to a **`ModeDefinition`** on your pipeline: | ||||
```python file=/deploying/dask_hello_world.py | ```python file=/deploying/dask_hello_world.py | ||||
from dagster import ModeDefinition, default_executors, fs_io_manager, pipeline, solid | from dagster import ( | ||||
ModeDefinition, | |||||
default_executors, | |||||
fs_io_manager, | |||||
pipeline, | |||||
solid, | |||||
) | |||||
from dagster_dask import dask_executor | from dagster_dask import dask_executor | ||||
@solid | @solid | ||||
def hello_world(): | def hello_world(): | ||||
return "Hello, World!" | return "Hello, World!" | ||||
▲ Show 20 Lines • Show All 82 Lines • Show Last 20 Lines |