Claire M.
09/06/2024, 8:15 AMself.catalog = kedro.io.DataCatalog()
self.pipeline = [function that defines the list of nodes]
self.runner = kedro.runner.SequentialRunner()
intermediate_outputs = set(self.pipeline.all_outputs()) - set(self.pipeline.outputs())
for output in intermediate_outputs:
self.catalog.add(output, MemoryDataset(copy_mode="assign"))
self.catalog.add("input_data", MemoryDataset(model_input, copy_mode="assign"))
predictions = self.runner.run(
pipeline=self.pipeline,
catalog=self.catalog,
)
So I have this Python Object in memory and I would like to create a diagram visualization of the pipeline.Jitendra Gundaniya
09/06/2024, 8:32 AMJuan Luis
09/06/2024, 8:37 AMNok Lam Chan
09/08/2024, 12:58 AM