Thread
#prefect-community
    s

    Slackbot

    4 months ago
    This message was deleted.
    Jason Motley

    Jason Motley

    4 months ago
    Kevin Kho

    Kevin Kho

    4 months ago
    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()