diff --git a/actes-princiers/src/actes_princiers/pipelines/xml_processing/nodes.py b/actes-princiers/src/actes_princiers/pipelines/xml_processing/nodes.py index 5187cb4..31b46ed 100755 --- a/actes-princiers/src/actes_princiers/pipelines/xml_processing/nodes.py +++ b/actes-princiers/src/actes_princiers/pipelines/xml_processing/nodes.py @@ -14,7 +14,7 @@ with KedroSession.create() as session: context = session.load_context() # 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" datasets = datasetcol.datasets housename = datasetcol._housename @@ -27,7 +27,7 @@ def parse_xml_collection(datasetcol: XMLDataSetCollection, params: str) -> XMLDa output_source_doc = dataset.transform() # set dataset's output filepath 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 output_xmldataset_dir = output_filepath.parent output_xmldataset_dir.mkdir(parents=True, exist_ok=True) diff --git a/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py b/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py index 4ee3b48..879539f 100755 --- a/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py +++ b/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py @@ -10,7 +10,7 @@ def create_pipeline(**kwargs) -> Pipeline: [ node( func=parse_xml_collection, - inputs=["bourbon", "params:xsltstylesheet"], + inputs=["bourbon"], outputs="bourbon_xmlcontent", name="bourbon_ds_collection", ),