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

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

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

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