rename make_json

develop
gwen 3 years ago
parent cf0d386ebf
commit f54fb4ba1c

@ -41,7 +41,7 @@ def parse_xml_collection(datasetcol: XMLDataSetCollection) -> XMLDataSetCollecti
return output_datasets 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" "node function entry point, performs batch processing"
datasets = datasetcol.datasets datasets = datasetcol.datasets
housename = datasetcol._housename housename = datasetcol._housename

@ -1,7 +1,7 @@
from kedro.pipeline import Pipeline, node, pipeline 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) # add_xmlcontent_tojson)
@ -15,7 +15,7 @@ def create_pipeline(**kwargs) -> Pipeline:
name="bourbon_ds_collection", name="bourbon_ds_collection",
), ),
node( node(
func=parse_json_collection, func=make_json_collection,
inputs="bourbon_json", inputs="bourbon_json",
outputs="bourbon_jsonoutput", outputs="bourbon_jsonoutput",
name="bourbon_json_ds_collection", name="bourbon_json_ds_collection",

Loading…
Cancel
Save