feat(sdk)!: move v1 to deprecated folder

backend/src/v2/test/sample_test.py

@@ -18,7 +18,7 @@
 import json
 import yaml
 from kubernetes import client as k8s_client
-import kfp
+import kfp.deprecated as kfp
 
 download_gcs_tgz = kfp.components.load_component_from_file(
     'components/download_gcs_tgz.yaml')

samples/core/AutoML tables/AutoML Tables - Retail product stockout prediction.ipynb

@@ -29,7 +29,7 @@
    "source": [
     "# AutoML Tables components\n",
     "\n",
-    "from kfp.components import load_component_from_url\n",
+    "from kfp.deprecated.components import load_component_from_url\n",
     "\n",
     "automl_create_dataset_for_tables_op        = load_component_from_url('https://raw.githubusercontent.com/kubeflow/pipelines/b3179d86b239a08bf4884b50dbf3a9151da96d66/components/gcp/automl/create_dataset_for_tables/component.yaml')\n",
     "automl_import_data_from_bigquery_source_op = load_component_from_url('https://raw.githubusercontent.com/kubeflow/pipelines/b3179d86b239a08bf4884b50dbf3a9151da96d66/components/gcp/automl/import_data_from_bigquery/component.yaml')\n",
@@ -47,7 +47,7 @@
    "outputs": [],
    "source": [
     "# Define the pipeline\n",
-    "import kfp\n",
+    "import kfp.deprecated as kfp\n",
     "\n",
     "def retail_product_stockout_prediction_pipeline_gcs(\n",
     "    gcp_project_id: str,\n",
@@ -161,4 +161,4 @@
  },
  "nbformat": 4,
  "nbformat_minor": 2
-}
+}

samples/core/XGBoost/xgboost_sample.py

@@ -1,5 +1,5 @@
-import kfp
-from kfp import components
+import kfp.deprecated as kfp
+from kfp.deprecated import components
 
 chicago_taxi_dataset_op = components.load_component_from_url(
     'https://raw.githubusercontent.com/kubeflow/pipelines/e3337b8bdcd63636934954e592d4b32c95b49129/components/datasets/Chicago%20Taxi/component.yaml'

samples/core/XGBoost/xgboost_sample_test.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
+import kfp.deprecated as kfp
 from .xgboost_sample import xgboost_pipeline
 from kfp.samples.test.utils import run_pipeline_func, TestCase
 

samples/core/caching/caching.ipynb

@@ -1,14 +1,18 @@
 {
  "cells": [
   {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
    "source": [
     "kfp_endpoint = None\n",
     "\n",
     "import datetime\n",
     "import time\n",
     "\n",
-    "import kfp\n",
-    "from kfp.components import create_component_from_func\n",
+    "import kfp.deprecated as kfp\n",
+    "from kfp.deprecated.components import create_component_from_func\n",
     "\n",
     "\n",
     "@create_component_from_func\n",
@@ -26,11 +30,7 @@
     "def caching_pipeline(seconds: float = 60):\n",
     "    # All outputs of successful executions are cached\n",
     "    work_task = do_work_op(seconds)\n"
-   ],
-   "cell_type": "code",
-   "metadata": {},
-   "execution_count": null,
-   "outputs": []
+   ]
   },
   {
    "cell_type": "code",

samples/core/caching/caching_sample.py

@@ -3,8 +3,8 @@
 import datetime
 import time
 
-import kfp
-from kfp.components import create_component_from_func
+import kfp.deprecated as kfp
+from kfp.deprecated.components import create_component_from_func
 
 
 @create_component_from_func

samples/core/caching/caching_test.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
+import kfp.deprecated as kfp
 from kfp.samples.test.utils import TestCase, relative_path, run_pipeline_func
 
 run_pipeline_func([

samples/core/condition/condition.py

@@ -12,9 +12,9 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
-from kfp import components
-from kfp import dsl
+from kfp.deprecated import components
+from kfp.deprecated import dsl
+from kfp.deprecated import compiler
 
 
 def flip_coin(force_flip_result: str = '') -> str:
@@ -48,4 +48,4 @@ def condition(text: str = 'condition test', force_flip_result: str = ''):
 
 
 if __name__ == '__main__':
-    kfp.compiler.Compiler().compile(condition, __file__ + '.yaml')
+    compiler.Compiler().compile(condition, __file__ + '.yaml')

samples/core/condition/condition_test.py

@@ -15,7 +15,7 @@
 from __future__ import annotations
 
 import unittest
-import kfp
+import kfp.deprecated as kfp
 import kfp_server_api
 from ml_metadata.proto import Execution
 from .condition import condition

samples/core/condition/nested_condition.py

@@ -12,8 +12,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-from kfp import components
-from kfp import dsl
+from kfp.deprecated import components
+from kfp.deprecated import dsl
 
 
 @components.create_component_from_func

samples/core/condition/nested_condition_test.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
+import kfp.deprecated as kfp
 from .nested_condition import my_pipeline
 from kfp.samples.test.utils import run_pipeline_func, TestCase
 

samples/core/continue_training_from_prod/continue_training_from_prod.py

@@ -10,8 +10,8 @@
 kfp_endpoint=None
 
 
-import kfp
-from kfp import components
+import kfp.deprecated as kfp
+from kfp.deprecated import components
 
 
 chicago_taxi_dataset_op = components.load_component_from_url('https://raw.githubusercontent.com/kubeflow/pipelines/e3337b8bdcd63636934954e592d4b32c95b49129/components/datasets/Chicago%20Taxi/component.yaml')
@@ -52,7 +52,7 @@ def continuous_training_pipeline(
         table=testing_data,
         transform_code='''df = df[["tips"]]''',
     ).set_display_name('True values').output
-    
+
     true_values = drop_header_op(true_values_table).output
 
     # Getting the active prod model
@@ -82,7 +82,7 @@ def continuous_training_pipeline(
             label_column=0,
         ).output
 
-        # Calculating the regression metrics    
+        # Calculating the regression metrics
         metrics_task = calculate_regression_metrics_from_csv_op(
             true_values=true_values,
             predicted_values=predictions,
@@ -106,7 +106,7 @@ def continuous_training_pipeline(
     with kfp.dsl.Condition(prod_model_uri != ""):
         # Downloading the model
         prod_model = download_from_gcs_op(prod_model_uri).output
-        
+
         # Training
         model = xgboost_train_on_csv_op(
             training_data=training_data,
@@ -123,7 +123,7 @@ def continuous_training_pipeline(
             label_column=0,
         ).output
 
-        # Calculating the regression metrics    
+        # Calculating the regression metrics
         metrics_task = calculate_regression_metrics_from_csv_op(
             true_values=true_values,
             predicted_values=predictions,

samples/core/dataflow/dataflow.ipynb

@@ -125,7 +125,7 @@
    },
    "outputs": [],
    "source": [
-    "import kfp.components as comp\n",
+    "import kfp.deprecated.components as comp\n",
     "\n",
     "dataflow_python_op = comp.load_component_from_url(\n",
     "    'https://raw.githubusercontent.com/kubeflow/pipelines/1.7.0-rc.3/components/gcp/dataflow/launch_python/component.yaml')"
@@ -325,8 +325,8 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "import kfp\n",
-    "import kfp.dsl as dsl\n",
+    "import kfp.deprecated as kfp\n",
+    "from kfp.deprecated import dsl, Client\n",
     "import json\n",
     "@dsl.pipeline(\n",
     "    name='dataflow-launch-python-pipeline',\n",
@@ -392,7 +392,7 @@
     }
    ],
    "source": [
-    "kfp.Client().create_run_from_pipeline_func(pipeline, arguments={})"
+    "Client().create_run_from_pipeline_func(pipeline, arguments={})"
    ]
   },
   {

samples/core/dataflow/dataflow_test.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
+import kfp.deprecated as kfp
 from kfp.samples.test.utils import TestCase, relative_path, run_pipeline_func
 
 run_pipeline_func([

samples/core/dns_config/dns_config.py

@@ -14,8 +14,8 @@
 # limitations under the License.
 
 
-import kfp
-from kfp import dsl
+import kfp.deprecated as kfp
+from kfp.deprecated import dsl, compiler
 from kubernetes.client.models import V1PodDNSConfig, V1PodDNSConfigOption
 
 
@@ -43,7 +43,7 @@ def dns_config_pipeline():
         options=[V1PodDNSConfigOption(name="ndots", value="2")]
     ))
 
-    kfp.compiler.Compiler().compile(
+    compiler.Compiler().compile(
         dns_config_pipeline,
         __file__ + '.yaml',
         pipeline_conf=pipeline_conf

samples/core/dsl_static_type_checking/dsl_static_type_checking.ipynb

@@ -107,7 +107,11 @@
   {
    "cell_type": "code",
    "execution_count": 2,
-   "metadata": {"tags":["skip-in-test"]},
+   "metadata": {
+    "tags": [
+     "skip-in-test"
+    ]
+   },
    "outputs": [
     {
      "name": "stdout",
@@ -245,9 +249,10 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "import kfp.components as comp\n",
-    "import kfp.dsl as dsl\n",
-    "import kfp.compiler as compiler\n",
+    "from kfp.deprecated import components as comp\n",
+    "from kfp.deprecated import dsl\n",
+    "from kfp.deprecated import compiler\n",
+    "\n",
     "# The components are loaded as task factories that generate container_ops.\n",
     "task_factory_a = comp.load_component_from_text(text=component_a)\n",
     "task_factory_b = comp.load_component_from_text(text=component_b)\n",
@@ -350,12 +355,13 @@
     }
    ],
    "source": [
-    "import kfp.components as comp\n",
-    "import kfp.dsl as dsl\n",
-    "import kfp.compiler as compiler\n",
-    "from kfp.dsl.types import InconsistentTypeException\n",
-    "task_factory_a = comp.load_component_from_text(text=component_a)\n",
-    "task_factory_b = comp.load_component_from_text(text=component_b)\n",
+    "from kfp.deprecated import components\n",
+    "from kfp.deprecated import dsl\n",
+    "from kfp.deprecated import compiler\n",
+    "from kfp.deprecated.dsl.types import InconsistentTypeException\n",
+    "\n",
+    "task_factory_a = components.load_component_from_text(text=component_a)\n",
+    "task_factory_b = components.load_component_from_text(text=component_b)\n",
     "\n",
     "#Use the component as part of the pipeline\n",
     "@dsl.pipeline(name='type-check-b',\n",
@@ -407,9 +413,9 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "from kfp.dsl import component\n",
-    "from kfp.dsl.types import Integer, GCSPath\n",
-    "from kfp.dsl import ContainerOp\n",
+    "from kfp.deprecated.dsl import component\n",
+    "from kfp.deprecated.dsl.types import Integer, GCSPath\n",
+    "from kfp.deprecated.dsl import ContainerOp\n",
     "# when components are defined based on the component decorator,\n",
     "# the type information is annotated to the input or function returns.\n",
     "# There are two ways to define the type: string or a dictionary with the openapi_schema_validator property\n",
@@ -497,9 +503,9 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "from kfp.dsl import component\n",
-    "from kfp.dsl.types import Integer, GCSPath\n",
-    "from kfp.dsl import ContainerOp\n",
+    "from kfp.deprecated.dsl import component\n",
+    "from kfp.deprecated.dsl.types import Integer, GCSPath\n",
+    "from kfp.deprecated.dsl import ContainerOp\n",
     "# task_factory_a outputs an input field_m with the openapi_schema_validator different\n",
     "# from the task_factory_b's input field_z.\n",
     "# One is gs:// and the other is gcs://\n",
@@ -620,9 +626,9 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "from kfp.dsl import component\n",
-    "from kfp.dsl.types import Integer, GCSPath\n",
-    "from kfp.dsl import ContainerOp\n",
+    "from kfp.deprecated.dsl import component\n",
+    "from kfp.deprecated.dsl.types import Integer, GCSPath\n",
+    "from kfp.deprecated.dsl import ContainerOp\n",
     "# task_factory_a lacks the type information for output filed_n\n",
     "# task_factory_b lacks the type information for input field_y\n",
     "# When no type information is provided, it matches all types.\n",
@@ -796,10 +802,10 @@
   "pycharm": {
    "stem_cell": {
     "cell_type": "raw",
-    "source": [],
     "metadata": {
      "collapsed": false
-    }
+    },
+    "source": []
    }
   }
  },

samples/core/dsl_static_type_checking/dsl_static_type_checking_test.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
+import kfp.deprecated as kfp
 from kfp.samples.test.utils import TestCase, relative_path, run_pipeline_func
 
 run_pipeline_func([

samples/core/execution_order/execution_order.py

@@ -14,9 +14,8 @@
 # limitations under the License.
 
 
-import kfp
-from kfp import dsl
-import kfp.components as comp
+from kfp.deprecated import dsl, compiler
+import kfp.deprecated.components as comp
 
 
 @comp.create_component_from_func
@@ -40,4 +39,4 @@ def execution_order_pipeline(text1: str='message 1', text2: str='message 2'):
   step2_task.after(step1_task)
 
 if __name__ == '__main__':
-  kfp.compiler.Compiler().compile(execution_order_pipeline, __file__ + '.yaml')
+  compiler.Compiler().compile(execution_order_pipeline, __file__ + '.yaml')

samples/core/execution_order/execution_order_test.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import kfp
+import kfp.deprecated as kfp
 from kfp.samples.test.utils import TestCase, relative_path, run_pipeline_func
 
 run_pipeline_func([