Tim Enders
06/09/2022, 2:39 PMfrom prefect.task_runner import DaskTaskRunner
ModuleNotFoundError: No module named 'prefect.task_runner'
Is there an extra that needs installed?Anna Geller
pip install prefect-dask
Kevin Kho
prefect.task_runners
?Anna Geller
from prefect_dask.task_runners import DaskTaskRunner
Tim Enders
06/09/2022, 2:42 PMfrom prefect import flow
from prefect.task_runner import DaskTaskRunner
@flow(task_runner=DaskTaskRunner(address="<http://my-dask-cluster>"))
def my_flow():
pass
Anna Geller
Tim Enders
06/09/2022, 2:44 PMprefect-dask
an extra, or separate dependency? I use poetry
to manage our stackAnna Geller
from prefect.task_runners import DaskTaskRunner
Kevin Kho
from prefect.task_runners import DaskTaskRunner
will work but eventually you will need prefect-dask
installedTim Enders
06/09/2022, 2:45 PM