Hi, I am trying to setup a Dask Executor but when try to deploy a flow using the DaskExecutor it says that Prefect cannot be found:

Unexpected error: ModuleNotFoundError("No module named 'prefect'")

I did specify Prefect in the environment variables of the pod specification, so I do not know why it cannot be found. If anyone can help me, please let me know 🙂. EDIT: Also I am using the KubeCluster class (dask_kubernetes.KubeCluster)

Hi @Fabrice Toussaint - I'm not an expert at set-up with Dask but does the following link and discussion help? https://prefect-community.slack.com/archives/C014Z8DPDSR/p1621458843051800

Hey @Fabrice Toussaint, you need to have prefect installed on the Dask workers. I assume your KubeCluster takes an image? Did you include prefect there? You can also use the base prefect image if you are using the base dask image because the base prefect image has dask