From f54fb4ba1c1bc7d505a46c8d68da9b45511192a1 Mon Sep 17 00:00:00 2001 From: gwen Date: Sat, 8 Jul 2023 16:32:23 +0200 Subject: [PATCH] rename make_json --- .../src/actes_princiers/pipelines/xml_processing/nodes.py | 2 +- .../src/actes_princiers/pipelines/xml_processing/pipeline.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) 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",