nickolas da rocha machado
10/10/2022, 2:47 PMpython
# pipeline_registry.py
pipelines["partitioned"] = Pipeline([node(print, 'partitioned', None)])
yml
# catalog.yml
partitioned:
type: PartitionedDataSet
dataset: pandas.CSVDataSet
path: abfs://...dfs.core.windows/...
credentials: lab
filename_suffix: .csv
log
[10/10/22 14:39:54] INFO Kedro project
[10/10/22 14:39:55] INFO Loading data from 'partitioned' (PartitionedDataSet)...