Related to my question above, but conceptually separate, if I have multiple outputs for a solid, how do I then attach those outputs to the proper parameters in the construction of the pipeline? Do I need to do that in a PipelineDefinition instance?

@pipeline
def multiple_outputs_pipeline():
    hot_cereals, cold_cereals = split_cereals(read_csv())
    sort_hot_cereals_by_calories(hot_cereals)
    sort_cold_cereals_by_calories(cold_cereals)

?

I'll give that a shot, thanks!