https://dagster.io/ logo
#announcements
Title
# announcements
t

Tobias Macey

05/13/2020, 8:56 PM
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?
s

schrockn

05/13/2020, 9:01 PM
Copy code
@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)
?
t

Tobias Macey

05/13/2020, 10:45 PM
I'll give that a shot, thanks!
2 Views