Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

Hey all, happy new year everyone. Hope everyone stays safe and healthy! I’m currently experimenting with an ETL architecture, and I read in the docs that Dask cluster was the preferred way of running a flow. But I couldn’t find examples of using the Executer within the functional API, only with the imperative API (`flow.run(executor=Dask`).

I did however started a Dask Cluster locally, and set the environment variables, as per the docs, but my tasks are still syncronous, and not running in parallel, and I can’t see anything in the dask workers logs. is there anything I should be doing to enjoy the speed and benefits of the parallel and distributed computation?

For anybody who comes across this in the future, I fixed by setting the `executer`  and the `environment`  like so:

```python
```executor = DaskExecutor()
environment = LocalEnvironment(executor)

with Flow('Distributed Flow', environment=environment) as flow:```

Heads up that we’d recommend using the new `RunConfigs` over environments. <https://docs.prefect.io/orchestration/flow_config/run_configs.html>