Tim Galvin
01/16/2023, 5:20 AMdask_jobqueue
. It makes sense to me to avoid a whole new set of requests when resources have already been allocated for the blocked parent flow.Ryan Peden
01/16/2023, 8:34 AMfrom prefect.context import get_run_context
# then, inside your parent flow
context = get_run_context()
task_runner = context.task_runner
result = my_subflow.with_options(task_runner=task_runner)(param1, param2)
Tim Galvin
01/16/2023, 8:39 AMflow
using it completes? Or do they just live until that are garbage collected by python?