empty pipeline

rnoxy · Nov 14, 2023 · 4cbd83f · 4cbd83f
1 parent 0e026d6
commit 4cbd83f
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 0 deletions.
diff --git a/....repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/__init__.py b/....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/...ter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/nodes.py b/...ter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/nodes.py
@@ -0,0 +1,3 @@
+import logging
+
+LOGGER = logging.getLogger(__name__)
diff --git a/....repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_processing/pipeline.py b/....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,
+    )
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		import logging

		LOGGER = logging.getLogger(__name__)