Ced miltoni
03/13/2025, 9:52 PMpytest
:
/test_pipeline.py::test_pipeline_execution - NameError: name 'MemoryDataSet' is not defined
If any body could help me please...
Bellow the test i try to add :
from <http://kedro.io|kedro.io> import MemoryDataset
from <http://kedro.io|kedro.io> import KedroDataCatalog
def test_pipeline_execution():
catalog = KedroDataCatalog({
"raw_repos": MemoryDataSet(),
"transformed_repos": MemoryDataSet(),
})
# define stub function instead of mock
def extract_repositories():
return [{"repo": "test-repo"}]
def transform_repositories(raw_repos):
return [{"repo": raw_repos[0]["repo"], "processed": True}]
def load_repositories(transformed_repos):
assert transformed_repos == [{"repo": "test-repo", "processed": True}]
pipeline = Pipeline([
node(extract_repositories, inputs=None, outputs="raw_repos"),
node(transform_repositories, inputs="raw_repos", outputs="transformed_repos"),
node(load_repositories, inputs="transformed_repos", outputs=None),
])
runner = SequentialRunner()
runner.run(pipeline, catalog)
Thanks in advanced guys.Hall
03/13/2025, 9:52 PMIan Whalen
03/13/2025, 10:19 PMMemoryDataSet
to MemoryDataset
where the set
is lower case