https://prefect.io logo
Title
e

Eric

09/21/2020, 11:33 PM
Hi all, trying to test out Dask w/ Prefect, getting this error when trying to run flow.run(executor=DaskExecutor()):
k

Kyle Moon-Wright

09/21/2020, 11:52 PM
Hey @Eric, I haven't encountered this error before, let me get some more information for you.
@Eric 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
.
e

Eric

09/22/2020, 12:24 AM
@Kyle Moon-Wright hey man, thanks for the reply! see below
k

Kyle Moon-Wright

09/22/2020, 12:36 AM
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.
e

Eric

09/22/2020, 5:41 PM
hey @Kyle Moon-Wright getting back ont his now, will follow up.