params.yaml suppression

develop
gwen 3 years ago
parent e1b34140f0
commit ae5fb47522

@ -14,7 +14,7 @@ with KedroSession.create() as session:
context = session.load_context() context = session.load_context()
# catalog = context.get_catalog() # catalog = context.get_catalog()
def parse_xml_collection(datasetcol: XMLDataSetCollection, params: str) -> XMLDataSetCollection: def parse_xml_collection(datasetcol: XMLDataSetCollection) -> XMLDataSetCollection:
"node function entry point, performs batch processing" "node function entry point, performs batch processing"
datasets = datasetcol.datasets datasets = datasetcol.datasets
housename = datasetcol._housename housename = datasetcol._housename
@ -27,7 +27,7 @@ def parse_xml_collection(datasetcol: XMLDataSetCollection, params: str) -> XMLDa
output_source_doc = dataset.transform() output_source_doc = dataset.transform()
# set dataset's output filepath # set dataset's output filepath
output_filepath = outputfolderpath / Path(dataset_filenamestem).with_suffix(".pseudoxml") output_filepath = outputfolderpath / Path(dataset_filenamestem).with_suffix(".pseudoxml")
output_xmldataset = EtreeXMLDataSet(str(output_filepath), params) output_xmldataset = EtreeXMLDataSet(str(output_filepath), output_datasets.xsltstylesheet)
# let's create subfolders, if they don't exist # let's create subfolders, if they don't exist
output_xmldataset_dir = output_filepath.parent output_xmldataset_dir = output_filepath.parent
output_xmldataset_dir.mkdir(parents=True, exist_ok=True) output_xmldataset_dir.mkdir(parents=True, exist_ok=True)

@ -10,7 +10,7 @@ def create_pipeline(**kwargs) -> Pipeline:
[ [
node( node(
func=parse_xml_collection, func=parse_xml_collection,
inputs=["bourbon", "params:xsltstylesheet"], inputs=["bourbon"],
outputs="bourbon_xmlcontent", outputs="bourbon_xmlcontent",
name="bourbon_ds_collection", name="bourbon_ds_collection",
), ),

Loading…
Cancel
Save