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

image.png

I don’t think that should be it? Well what is the return of the task?

You can test like this:
```from prefect import Flow, task, unmapped
import prefect

@task
def retrieve_episode_ids():
    return [1,2,3,4,5]

@task()
def reduce(x, y):
    return x

with Flow("import_episodes") as flow:
    episode_ids = retrieve_episode_ids()
    reduce.map(episode_ids, y=unmapped("'test'"))

flow.run()```