def create_pipeline(**kwargs):
    build_list_of_entity_nodes = node(
        func=generate_nodes_from_entities,
        inputs="entities_csv",
        outputs="list_of_entity_nodes"
    )
    ## 
    #  How do I run my_expensive_entity_function across this list of nodes,
    #  which is determined through the contents of entities_csv
    return Pipeline([build_list_of_entity_nodes])