We are currently solving the following issue within our repository. Here is the issue text:
--- BEGIN ISSUE ---
[pH] v2 sample test - enable kaniko caching
https://cloud.google.com/build/docs/kaniko-cache

this will help improve local testing speed
https://github.com/kubeflow/pipelines/blob/master/v2/test/components/kaniko.yaml

--- END ISSUE ---

Below are some code segments, each from a relevant file. One or more of these files may contain bugs.
--- BEGIN FILES ---
Path: `samples/v2/hello_world.py`
Content:
```
1 # Copyright 2021 The Kubeflow Authors
2 #
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at
6 #
7 #      http://www.apache.org/licenses/LICENSE-2.0
8 #
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
14 
15 from kfp.v2 import dsl
16 from kfp.v2 import compiler
17 from kfp.v2 import components
18 
19 
20 @components.create_component_from_func
21 def hello_world(text: str):
22     print(text)
23     return text
24 
25 
26 @dsl.pipeline(name='hello-world', description='A simple intro pipeline')
27 def pipeline_parameter_to_consumer(text: str = 'hi there'):
28     '''Pipeline that passes small pipeline parameter string to consumer op'''
29 
30     consume_task = hello_world(
31         text
32     )  # Passing pipeline parameter as argument to consumer op
33 
34 
35 if __name__ == "__main__":
36     # execute only if run as a script
37     compiler.Compiler().compile(
38         pipeline_func=pipeline_parameter_to_consumer,
39         package_path='hello_world_pipeline.json'
40     )
41
```
--- END FILES ---

Please first localize the bug based on the issue statement, and then generate a patch according to the `git diff` format fenced by three backticks.

Here is an example:

```diff
diff --git a/examples/server_async.py b/examples/server_async.py
--- a/examples/server_async.py
+++ b/examples/server_async.py
@@ -313,4 +313,4 @@
 
 
 if __name__ == "__main__":
-    asyncio.run(run_async_server("."), debug=True)
+    asyncio.run(run_async_server(), debug=True)
diff --git a/examples/server_sync.py b/examples/server_sync.py
--- a/examples/server_sync.py
+++ b/examples/server_sync.py
@@ -313,5 +313,5 @@
 
 
 if __name__ == "__main__":
-    server = run_sync_server(".")
+    server = run_sync_server()
     server.shutdown()

```

diff --git a/samples/v2/hello_world.py b/samples/v2/hello_world.py
--- a/samples/v2/hello_world.py
+++ b/samples/v2/hello_world.py
@@ -24,7 +24,7 @@
 
 
 @dsl.pipeline(name='hello-world', description='A simple intro pipeline')
-def pipeline_parameter_to_consumer(text: str = 'hi there'):
+def pipeline_hello_world(text: str = 'hi there'):
     '''Pipeline that passes small pipeline parameter string to consumer op'''
 
     consume_task = hello_world(
@@ -35,6 +35,6 @@
 if __name__ == "__main__":
     # execute only if run as a script
     compiler.Compiler().compile(
-        pipeline_func=pipeline_parameter_to_consumer,
+        pipeline_func=pipeline_hello_world,
         package_path='hello_world_pipeline.json'
     )

{"golden_diff": "diff --git a/samples/v2/hello_world.py b/samples/v2/hello_world.py\n--- a/samples/v2/hello_world.py\n+++ b/samples/v2/hello_world.py\n@@ -24,7 +24,7 @@\n \n \n @dsl.pipeline(name='hello-world', description='A simple intro pipeline')\n-def pipeline_parameter_to_consumer(text: str = 'hi there'):\n+def pipeline_hello_world(text: str = 'hi there'):\n     '''Pipeline that passes small pipeline parameter string to consumer op'''\n \n     consume_task = hello_world(\n@@ -35,6 +35,6 @@\n if __name__ == \"__main__\":\n     # execute only if run as a script\n     compiler.Compiler().compile(\n-        pipeline_func=pipeline_parameter_to_consumer,\n+        pipeline_func=pipeline_hello_world,\n         package_path='hello_world_pipeline.json'\n     )\n", "issue": "[pH] v2 sample test - enable kaniko caching\nhttps://cloud.google.com/build/docs/kaniko-cache\r\n\r\nthis will help improve local testing speed\r\nhttps://github.com/kubeflow/pipelines/blob/master/v2/test/components/kaniko.yaml\n", "before_files": [{"content": "# Copyright 2021 The Kubeflow Authors\n#\n# Licensed under the Apache License, Version 2.0 (the \"License\");\n# you may not use this file except in compliance with the License.\n# You may obtain a copy of the License at\n#\n#      http://www.apache.org/licenses/LICENSE-2.0\n#\n# Unless required by applicable law or agreed to in writing, software\n# distributed under the License is distributed on an \"AS IS\" BASIS,\n# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n# See the License for the specific language governing permissions and\n# limitations under the License.\n\nfrom kfp.v2 import dsl\nfrom kfp.v2 import compiler\nfrom kfp.v2 import components\n\n\n@components.create_component_from_func\ndef hello_world(text: str):\n    print(text)\n    return text\n\n\n@dsl.pipeline(name='hello-world', description='A simple intro pipeline')\ndef pipeline_parameter_to_consumer(text: str = 'hi there'):\n    '''Pipeline that passes small pipeline parameter string to consumer op'''\n\n    consume_task = hello_world(\n        text\n    )  # Passing pipeline parameter as argument to consumer op\n\n\nif __name__ == \"__main__\":\n    # execute only if run as a script\n    compiler.Compiler().compile(\n        pipeline_func=pipeline_parameter_to_consumer,\n        package_path='hello_world_pipeline.json'\n    )\n", "path": "samples/v2/hello_world.py"}], "after_files": [{"content": "# Copyright 2021 The Kubeflow Authors\n#\n# Licensed under the Apache License, Version 2.0 (the \"License\");\n# you may not use this file except in compliance with the License.\n# You may obtain a copy of the License at\n#\n#      http://www.apache.org/licenses/LICENSE-2.0\n#\n# Unless required by applicable law or agreed to in writing, software\n# distributed under the License is distributed on an \"AS IS\" BASIS,\n# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n# See the License for the specific language governing permissions and\n# limitations under the License.\n\nfrom kfp.v2 import dsl\nfrom kfp.v2 import compiler\nfrom kfp.v2 import components\n\n\n@components.create_component_from_func\ndef hello_world(text: str):\n    print(text)\n    return text\n\n\n@dsl.pipeline(name='hello-world', description='A simple intro pipeline')\ndef pipeline_hello_world(text: str = 'hi there'):\n    '''Pipeline that passes small pipeline parameter string to consumer op'''\n\n    consume_task = hello_world(\n        text\n    )  # Passing pipeline parameter as argument to consumer op\n\n\nif __name__ == \"__main__\":\n    # execute only if run as a script\n    compiler.Compiler().compile(\n        pipeline_func=pipeline_hello_world,\n        package_path='hello_world_pipeline.json'\n    )\n", "path": "samples/v2/hello_world.py"}]}