https://prefect.io logo
a

Andreas Nord

07/27/2023, 8:12 AM
I have a flow on which I specified to use SequentialTaskRunner:
Copy code
@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?
2 Views