I have a flow function decorated with @flow and specify a DaskTaskRunner. I thought this would cause my tasks to get run on my Dask cluster but I saw this in your documentation: “To run your task with a task runner, you must call the task with .submit().” Is this still true even if my flow function is configured as described above?

Hey @Tony Piazza that's correct they do need to be called using .submit to benefit from using the dask task runner "To run tasks asynchronously use the

.submit

method when you call them. If you call a task as you would normally in Python code it will run synchronously, even if you are calling the task within a flow that uses the

ConcurrentTaskRunner

,

DaskTaskRunner

, or

RayTaskRunner

." From this doc: https://docs.prefect.io/tutorials/dask-ray-task-runners/