diff --git a/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/__init__.py b/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/__init__.py
new file mode 100644
index 0000000..b1e511a
--- /dev/null
+++ b/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/__init__.py	
@@ -0,0 +1,5 @@
+from .pipeline import create_pipeline
+
+__all__ = ["create_pipeline"]
+
+__version__ = "0.1"
diff --git a/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/nodes.py b/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/nodes.py
new file mode 100644
index 0000000..d69b3ba
--- /dev/null
+++ b/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/nodes.py	
@@ -0,0 +1,3 @@
+import logging
+
+LOGGER = logging.getLogger(__name__)
diff --git a/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/pipeline.py b/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/pipeline.py
new file mode 100644
index 0000000..9b11fae
--- /dev/null
+++ b/mini-poetry/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/pipeline.py	
@@ -0,0 +1,18 @@
+from kedro.pipeline import Pipeline, pipeline, node
+
+def create_pipeline(**kwargs) -> Pipeline:
+    return pipeline(
+        [
+            node(
+                func=lambda x: x,
+                inputs="raw_data",
+                outputs="processed_data",
+                name="data_processing",
+            )
+        ],
+        inputs=None,
+        outputs=None,
+        parameters=None,
+        namespace=None,
+        tags=None,
+    )