datascience/actes-princiers/src/actes_princiers/pipelines/xml_processing/pipeline.py

from kedro.pipeline import Pipeline, node, pipeline
from kedro.framework.session import KedroSession

from .nodes import parse_xsl
import logging

logger = logging.getLogger(__name__)

# we need the context here in order to access to prepare_pipeline_creation()
with KedroSession.create() as session:
    context = session.load_context()
    # important: **we have to call** the catalog as an attribute, 
    # because it makes a call to the _get_catalog() of the context method
    catalog = context.catalog
    logger.info("loading houses")
    logger.info("------------------ houses ---------------------")
    logger.info(str(context.get_houses()))

def nodes_factory(nodes_description):
    "nodes creation"
    nodes = []
    for node_description in nodes_description:
        nodes.append(node(
                func=parse_xsl,
                inputs=[node_description['inputs'], "params:xlststylesheet"],
                outputs=node_description['outputs'],
                name=node_description['name'],
                tags="xsl",
            ))
    return nodes

def create_pipeline(**kwargs):
    "pipeline entry point needed by the global pipeline registry"
    return pipeline(nodes_factory(context.prepare_pipeline_creation()))