Update pipeline to Pipeline in docs (#5155)

* Update pipeline to Pipeline in docs

Signed-off-by: Ankita Katiyar <[email protected]>

* Also update test starter

Signed-off-by: Ankita Katiyar <[email protected]>

---------

Signed-off-by: Ankita Katiyar <[email protected]>

Author: ankatiyar

docs/tutorials/add_another_pipeline.md

@@ -297,40 +297,40 @@ First, add namespaces to the modelling component of the data science pipeline to
 
 ??? example "View code"
     ```python
-    from kedro.pipeline import Pipeline, node, pipeline
+    from kedro.pipeline import Node, Pipeline
 
     from .nodes import evaluate_model, split_data, train_model
 
 
     def create_pipeline(**kwargs) -> Pipeline:
-        pipeline_instance = pipeline(
+        pipeline_instance = Pipeline(
             [
-                node(
+                Node(
                     func=split_data,
                     inputs=["model_input_table", "params:model_options"],
                     outputs=["X_train", "X_test", "y_train", "y_test"],
                     name="split_data_node",
                 ),
-                node(
+                Node(
                     func=train_model,
                     inputs=["X_train", "y_train"],
                     outputs="regressor",
                     name="train_model_node",
                 ),
-                node(
+                Node(
                     func=evaluate_model,
                     inputs=["regressor", "X_test", "y_test"],
                     outputs=None,
                     name="evaluate_model_node",
                 ),
             ]
         )
-        ds_pipeline_1 = pipeline(
+        ds_pipeline_1 = Pipeline(
             nodes=pipeline_instance,
             inputs="model_input_table",
             namespace="active_modelling_pipeline",
         )
-        ds_pipeline_2 = pipeline(
+        ds_pipeline_2 = Pipeline(
             nodes=pipeline_instance,
             inputs="model_input_table",
             namespace="candidate_modelling_pipeline",
@@ -442,13 +442,13 @@ You can see this snippet as part of the code you added to the example:
     ```python
     ...
 
-    ds_pipeline_1 = pipeline(
+    ds_pipeline_1 = Pipeline(
         nodes=pipeline_instance,
         inputs="model_input_table",
         namespace="active_modelling_pipeline",
     )
 
-    ds_pipeline_2 = pipeline(
+    ds_pipeline_2 = Pipeline(
         nodes=pipeline_instance,
         inputs="model_input_table",
         namespace="candidate_modelling_pipeline",

docs/tutorials/create_a_pipeline.md

@@ -89,23 +89,23 @@ Next, take a look at `src/spaceflights/pipelines/data_processing/pipeline.py` wh
 
 ??? example "View code"
     ```python
-    from kedro.pipeline import Pipeline, node, pipeline
+    from kedro.pipeline import Node, Pipeline
 
     from .nodes import preprocess_companies, preprocess_shuttles
 
     ...
 
 
     def create_pipeline(**kwargs) -> Pipeline:
-        return pipeline(
+        return Pipeline(
             [
-                node(
+                Node(
                     func=preprocess_companies,
                     inputs="companies",
                     outputs="preprocessed_companies",
                     name="preprocess_companies_node",
                 ),
-                node(
+                Node(
                     func=preprocess_shuttles,
                     inputs="shuttles",
                     outputs="preprocessed_shuttles",
@@ -228,27 +228,27 @@ The node is created in `src/kedro_tutorial/pipelines/data_processing/pipeline.py
 
 ??? example "View code"
     ```python
-    from kedro.pipeline import Pipeline, node, pipeline
+    from kedro.pipeline import Node, Pipeline
 
     from .nodes import create_model_input_table, preprocess_companies, preprocess_shuttles
 
 
     def create_pipeline(**kwargs) -> Pipeline:
-        return pipeline(
+        return Pipeline(
             [
-                node(
+                Node(
                     func=preprocess_companies,
                     inputs="companies",
                     outputs="preprocessed_companies",
                     name="preprocess_companies_node",
                 ),
-                node(
+                Node(
                     func=preprocess_shuttles,
                     inputs="shuttles",
                     outputs="preprocessed_shuttles",
                     name="preprocess_shuttles_node",
                 ),
-                node(
+                Node(
                     func=create_model_input_table,
                     inputs=["preprocessed_shuttles", "preprocessed_companies", "reviews"],
                     outputs="model_input_table",

docs/tutorials/test_a_project.md

@@ -137,26 +137,26 @@ Consider the data science pipeline as a whole:
 
 ??? example "View code"
     ```python
-    from kedro.pipeline import Pipeline, node, pipeline
+    from kedro.pipeline import Node, Pipeline
     from .nodes import evaluate_model, split_data, train_model
 
 
     def create_pipeline(**kwargs) -> Pipeline:
-        return pipeline(
+        return Pipeline(
             [
-                node(
+                Node(
                     func=split_data,
                     inputs=["model_input_table", "params:model_options"],
                     outputs=["X_train", "X_test", "y_train", "y_test"],
                     name="split_data_node",
                 ),
-                node(
+                Node(
                     func=train_model,
                     inputs=["X_train", "y_train"],
                     outputs="regressor",
                     name="train_model_node",
                 ),
-                node(
+                Node(
                     func=evaluate_model,
                     inputs=["regressor", "X_test", "y_test"],
                     outputs=None,

features/test_starter/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_engineering/pipeline.py

@@ -4,15 +4,15 @@
 Delete this when you start working on your own Kedro project.
 """
 
-from kedro.pipeline import node, pipeline
+from kedro.pipeline import Node, Pipeline
 
 from .nodes import split_data
 
 
 def create_pipeline(**kwargs):
-    return pipeline(
+    return Pipeline(
         [
-            node(
+            Node(
                 split_data,
                 ["example_iris_data", "params:example_test_data_ratio"],
                 dict(

features/test_starter/{{ cookiecutter.repo_name }}/src/{{ cookiecutter.python_package }}/pipelines/data_science/pipeline.py

@@ -4,24 +4,24 @@
 Delete this when you start working on your own Kedro project.
 """
 
-from kedro.pipeline import node, pipeline
+from kedro.pipeline import Node, Pipeline
 
 from .nodes import predict, report_accuracy, train_model
 
 
 def create_pipeline(**kwargs):
-    return pipeline(
+    return Pipeline(
         [
-            node(
+            Node(
                 train_model,
                 ["example_train_x", "example_train_y", "parameters"],
                 "example_model",
             ),
-            node(
+            Node(
                 predict,
                 dict(model="example_model", test_x="example_test_x"),
                 "example_predictions",
             ),
-            node(report_accuracy, ["example_predictions", "example_test_y"], None),
+            Node(report_accuracy, ["example_predictions", "example_test_y"], None),
         ]
     )