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

image.png

Hi all, trying to test out Dask w/ Prefect, getting this error when trying to run flow.run(executor=DaskExecutor()):

Hey <@URXS0U84C>,
I haven't encountered this error before, let me get some more information for you.

<@URXS0U84C> What version of `distributed` and `dask` are you currently running? One potential cause for this error could be the utilization of a development version of `distributed`.

<@UUDFU628J> hey man, thanks for the reply! see below

Hmm, looking into this - there may be some issue with your environment and its dependencies. If you run `print(dask.__version__)` and `print(distributed.__version__)` in your IDE, what versions are returned?

We can check potential issues with dependencies by comparing versions between your `pip freeze` and the versions of those packages used by the IDE.

hey <@UUDFU628J> getting back ont his now, will follow up.