Kyle
@flow(task_runner=ConcurrentTaskRunner()) def map_task1(): @flow(task_runner=ConcurrentTaskRunner()) def map_task2(): @flow(task_runner=SequentialTaskRunner()) def flowrun():