prompt: 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()
  
  ```
  
golden_diff: 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'
       )
  
verification_info: {"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"}]}