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

I’m trying to run a local dask cluster in a non-task (only python) function, and it crashes immediately with `distributed.comm.core.CommClosedError`. This doesn’t happen anywhere else, other than in Prefect. Is there something to note when starting a local dask cluster in a prefect agent on k8s?