Merge branch 'release/1.1.0' into production

* release/1.1.0:
  1.1.0
  bump kfp to v1.8.12
  (trival) fix unittest about InputPath

Author: lynnmatrix

README.md

@@ -1,7 +1,7 @@
 # kfp-local
 Pipelines built with [kfp(kubeflow pipeline)](https://github.com/kubeflow/pipelines) execute in k8s cluster.
 
-During the development of kubeflow pipeline components, we usually upload the pipeline to kfp server and run it in k8s, if anything wrong we fix it locally and upload it again. 
+During the development of kubeflow pipeline components, we usually upload the pipeline to kfp server and run it in k8s, if anything wrong we fix it locally and upload it again.
 
 It should be helpful for the development efficiency if the above process takes place in local host, that's what `kfp-local` cares.
 
@@ -22,7 +22,7 @@ result = local_client.create_run_from_pipeline_func(
         )
 if result.success:
     a_output_filepath = result.get_output_file(task_name="a-task", output="a_output_name")
-    
+
 ```
 
 ## Additional configuration
@@ -31,7 +31,7 @@ The demo code in [Usage](#Usage) executes pipeline in local process with *Execut
 
 There are some options of `ExecutionMode`:
 * mode: Default execution mode, default 'docker'
-  
+
 * images_to_exclude: If the image of op is in images_to_exclude, the op is
     executed in the mode different from default_mode.
 
@@ -42,7 +42,7 @@ There are some options of `ExecutionMode`:
 For more information about how to make use of kfp_local, please refer to unit test.
 
 ## kfp compatibility
-kfp-local is tested with kfp=1.8.9 for now.
+kfp-local is tested with kfp>=1.8.9,<2.0 for now.
 
 Supports:
 * Control flow: Condition, ParallelFor, ExitHandler
@@ -51,4 +51,4 @@ Supports:
 Don't support for now:
 * Importer
 * Artifact iterator
-* Caching
+* Caching

kfp_local/_local_client.py

@@ -120,11 +120,6 @@ def __init__(self, pipeline_root: Optional[str] = None) -> None:
             pipeline_root: The root directory where the output artifact of component
               will be saved.
         """
-        warnings.warn(
-            "LocalClient is an Alpha[1] feature. It may be deprecated in the future.\n"
-            "[1] https://github.com/kubeflow/pipelines/blob/master/docs/release/feature-stages.md#alpha",  # noqa: E501
-            category=FutureWarning,
-        )
 
         _pipeline_root = pipeline_root or tempfile.tempdir
 

kfp_local/_version.py

@@ -1 +1 @@
-__version__ = "1.0.1"
+__version__ = "1.1.0"

kfp_local/local_client_test.py

@@ -28,7 +28,7 @@ def flip_coin() -> str:
 
 
 @dsl.component
-def component_with_inputpath(src: dsl.InputPath(str)) -> str:
+def component_with_inputpath(src: dsl.InputPath()) -> str:
     with open(src, "r") as f:
         return f.read()
 

requirements.in

@@ -1,4 +1 @@
-kfp==1.8.9
-
-
-
+kfp>=1.8.12,<2.0

requirements.txt

@@ -4,7 +4,7 @@
 #
 #    pip-compile
 #
-absl-py==0.11.0
+absl-py==1.0.0
     # via kfp
 attrs==21.4.0
     # via jsonschema
@@ -29,11 +29,12 @@ docstring-parser==0.13
     # via kfp
 fire==0.4.0
     # via kfp
-google-api-core==2.7.1
+google-api-core==2.7.2
     # via
     #   google-api-python-client
     #   google-cloud-core
     #   google-cloud-storage
+    #   kfp
 google-api-python-client==1.12.11
     # via kfp
 google-auth==1.35.0
@@ -47,7 +48,7 @@ google-auth==1.35.0
     #   kubernetes
 google-auth-httplib2==0.1.0
     # via google-api-python-client
-google-cloud-core==2.2.3
+google-cloud-core==2.3.0
     # via google-cloud-storage
 google-cloud-storage==1.44.0
     # via kfp
@@ -69,7 +70,7 @@ importlib-metadata==4.11.3
     #   jsonschema
 jsonschema==3.2.0
     # via kfp
-kfp==1.8.9
+kfp==1.8.12
     # via -r requirements.in
 kfp-pipeline-spec==0.1.14
     # via kfp
@@ -83,6 +84,7 @@ protobuf==3.20.0
     # via
     #   google-api-core
     #   google-cloud-storage
+    #   googleapis-common-protos
     #   kfp
     #   kfp-pipeline-spec
 pyasn1==0.4.8
@@ -93,7 +95,7 @@ pyasn1-modules==0.2.8
     # via google-auth
 pydantic==1.9.0
     # via kfp
-pyparsing==3.0.7
+pyparsing==3.0.8
     # via httplib2
 pyrsistent==0.18.1
     # via jsonschema

setup.py

@@ -25,7 +25,7 @@ def _load_description() -> str:
 
 
 def _load_requires(
-    requirements="requirements.txt",
+    requirements="requirements.in",
 ) -> List[str]:
     requirements_path = os.path.join(ROOT_PATH, requirements)
     with open(requirements_path) as f: