^ i think i figured it out. do this look correct? (also removed .submit()) ```@flow(task_runner=Conc...

Kyle

07/10/2023, 10:52 PM

^ i think i figured it out. do this look correct? (also removed .submit())

Copy code

@flow(task_runner=ConcurrentTaskRunner())  
def map_task1():

@flow(task_runner=ConcurrentTaskRunner())  
def map_task2():

@flow(task_runner=SequentialTaskRunner())
def flowrun():

2 Views

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.