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 28ca9e9..92df7ec 100755 --- a/actes-princiers/src/actes_princiers/pipelines/xml_processing/nodes.py +++ b/actes-princiers/src/actes_princiers/pipelines/xml_processing/nodes.py @@ -41,7 +41,7 @@ def parse_xml_collection(datasetcol: XMLDataSetCollection) -> XMLDataSetCollecti return output_datasets -def parse_json_collection(datasetcol: BsXMLDataSetCollection) -> Dict[str, BsXMLDataSet]: +def make_json_collection(datasetcol: BsXMLDataSetCollection) -> Dict[str, BsXMLDataSet]: "node function entry point, performs batch processing" datasets = datasetcol.datasets housename = datasetcol._housename 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 dd76016..0f5406e 100755 --- a/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py +++ b/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py @@ -1,7 +1,7 @@ from kedro.pipeline import Pipeline, node, pipeline -from .nodes import (parse_xml_collection, parse_json_collection) +from .nodes import (parse_xml_collection, make_json_collection) # add_xmlcontent_tojson) @@ -15,7 +15,7 @@ def create_pipeline(**kwargs) -> Pipeline: name="bourbon_ds_collection", ), node( - func=parse_json_collection, + func=make_json_collection, inputs="bourbon_json", outputs="bourbon_jsonoutput", name="bourbon_json_ds_collection",