Note to anyone using DaskTaskRunner
or RayTaskRunner
:
from prefect version 2.0b8
onwards, those task runners were moved to the respective Prefect Collections for better code dependency management (the core library no longer requires dask or ray as dependencies - now, those can be installed sepataely when needed).
The correct imports are now:
from prefect_dask import DaskTaskRunner
from prefect_ray import RayTaskRunner