https://prefect.io logo
s

Slackbot

05/02/2022, 4:42 PM
This message was deleted.
j

Jason Motley

05/02/2022, 4:43 PM
k

Kevin Kho

05/02/2022, 4:49 PM
I don’t think that should be it? Well what is the return of the task?
You can test like this:
Copy code
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()
8 Views