Hi all, trying to test out Dask w/ Prefect, gettin...
# prefect-community
e
Hi all, trying to test out Dask w/ Prefect, getting this error when trying to run flow.run(executor=DaskExecutor()):
k
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
@Kyle Moon-Wright hey man, thanks for the reply! see below
k
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
hey @Kyle Moon-Wright getting back ont his now, will follow up.