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.

Prefect Community

What is the Prefect 2 equivalent of `apply_map`? Details in :thread:

Previously flow looked like this:
```from prefect import apply_map, Flow

from mycode import task1, task2, task3, get_org

def extract_from_file(file: dict, organization: str):
    task1_results = task1(file['key'])
    task2_results = task2(file['another_key'])
    task3_results = task3(file['yet_another_key'], organization)
    

with Flow('this-flow', ) as this_flow:
    files = Parameter('files')
    organization = get_org()
    flow_file = apply_map(
        extract_from_file,
        file=files,
        organization=unmapped(organization),
    )```


Like this?
```for file in files:
    task1.submit(file["key"])
    task2.submit(file["another_key"])
    etc...```

I don’t think there’s a direct equivalent yet, since it most cases it’ll be more readable to just loop

If you want parallelism with multiprocessing you need to use a Dask task runner.