williamc
04/07/2022, 6:46 PMpipeline wrapper is of the form {'existing_param':'new_param'}. However I'm getting an error similar to kedro.pipeline.modular_pipeline.ModularPipelineError: Failed to map datasets and/or parameters: existing_param.
Digging up a bit I found the code that checks the existence of the parameters:
existing = {_strip_transcoding(ds) for ds in pipe.data_sets()}
non_existent = (inputs | outputs | parameters) - existing
if non_existent:
raise ModularPipelineError(
f"Failed to map datasets and/or parameters: "
f"{', '.join(sorted(non_existent))}"
)
What I don't understand is that existing only includes datasets, not params. What am I missing here 😅