Convention for kedro pipelines; pretend dashes are / in the file names for folder structure

src-my_project-pipelines-do_stuff-__init__.py

"""
This is the pipeline `do_stuff`
generated using kedro <blah>
"""

from .pipeline_do_stuff import create_pipeline

__all__ = ["create_pipeline"]

__version__ = "0.1"

src-my_project-pipelines-do_stuff-pipeline_do_stuff.py

"""
This is the pipeline `do_stuff`
generated using kedro <blah>
"""
from kedro.pipeline import Pipeline, pipeline
from utils import make_node

def create_pipeline(**kwargs) -> Pipeline:
  return pipeline([
    add_one,
    divide_by_two
  ])


##### nodes #####
@make_node(name="add_one", inputs="x", outputs="y")
def add_one(x):
  return x + 1

@make_node(name="divide_by_two", inputs="y", outputs="z")
def divide_by_two(y):
  return y / 2.

src-utils-__init__.py

from .node_decorator import make_node

src-utils-node_decorator.py

from kedro.pipeline import node

def make_node(**kwargs):
  return lambda func: node(func=func, **kwargs)