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?