I have a flow on which I specified to use SequentialTaskRunner: ```@flow(task_runner=SequentialTaskR...

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?

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.