Emilio Gagliardi
07/03/2023, 6:39 PMdef register_pipelines() -> Dict[str, Pipeline]:
"""Register the project's pipelines.
Returns:
A mapping from pipeline names to ``Pipeline`` objects.
"""
pipelines = find_pipelines()
pipelines["__default__"] = sum(pipelines.values())
return pipelines
However, in the spaceflights tutorial videos I'm watching, the host doesn't use the above code. instead they add the following:
data_processing_pipeline = dp.create_pipeline()
return{"__default__": data_processing_pipeline,
"dp":data_processing_pipeline}
So I'm unclear what I'm supposed to do for my own project. Do I just use the sum(pipelines.values()) or do I manually add pipelines as in the second block? THanks kindly,Yetunde
07/03/2023, 9:15 PMdef register_pipelines() -> Dict[str, Pipeline]:
"""Register the project's pipelines.
Returns:
A mapping from pipeline names to ``Pipeline`` objects.
"""
pipelines = find_pipelines()
pipelines["__default__"] = sum(pipelines.values())
return pipelines
To ensure that users didn't have to do this but kept the file so that users can make their own combinations of pipelines if they want to by editing the file, the code you see in:
data_processing_pipeline = dp.create_pipeline()
return{"__default__": data_processing_pipeline,
"dp":data_processing_pipeline}
Works as well. My question is, which video are you watching? We need to update this.Emilio Gagliardi
07/03/2023, 9:52 PMDeepyaman Datta
07/03/2023, 10:14 PMdef register_pipelines() -> Dict[str, Pipeline]:
"""Register the project's pipelines.
Returns:
A mapping from pipeline names to ``Pipeline`` objects.
"""
pipelines = find_pipelines()
pipelines["__default__"] = sum(pipelines.values())
pipelines["no_modeling_for_me"] = pipelines["de"] + pipelines["dp"] # assume de and dp modular pipelines exist
return pipelines
Emilio Gagliardi
07/03/2023, 10:51 PM