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
    def retrieve_episode_ids():
        return [1,2,3,4,5]
    def reduce(x, y):
        return x
    with Flow("import_episodes") as flow:
        episode_ids = retrieve_episode_ids(), y=unmapped("'test'"))