Question for the prefect devs in the know. Is there going to be upcoming support for allowing two separate task runners to support the processing of tasks within the one flow? I see that within the

Task

class the task runner attribute is close to being explosed. I ask this because I have a set of tasks that require large compute resources, and others that require small. I would love to be able to define two different dask task runners to handle both of these use cases, and specify which to use when calling my task function. Something like

Task(my_func).with_options(task_runner=small_dask_runner)

I tried to figure this out once, but I could not figure out how to start the event loop of the second dask runner correctly.