This is what I have in mind, there could be a better way. Rather than outputting a list of nodes, I think you need to first create the list of nodes then pass that list into the Pipeline object. Each node in the list would have a specific entity as input, which means you’d also have you split the csv yourself into separate entities.