I have a flow on which I specified to use SequentialTaskRunner:

@flow(task_runner=SequentialTaskRunner())
def seq_flow():
    subflow1()
    subflow2()

How do I make sure that any subflows (and recursively subflows of subflows) also use this task runner?