diff --git a/backend/src/v2/test/scripts/ci-env.sh b/backend/src/v2/test/scripts/ci-env.sh index d6aba1fbf56..ce81136520f 100644 --- a/backend/src/v2/test/scripts/ci-env.sh +++ b/backend/src/v2/test/scripts/ci-env.sh @@ -17,7 +17,7 @@ PROJECT="${PROJECT:-kfp-ci}" GCS_ROOT="gs://${PROJECT}/${COMMIT_SHA}/v2-sample-test" GCR_ROOT="gcr.io/${PROJECT}/${COMMIT_SHA}/v2-sample-test" # This is kfp-ci endpoint. -HOST=http://localhost:8888 +HOST=${HOST:-"https://$(curl https://raw.githubusercontent.com/kubeflow/testing/master/test-infra/kfp/endpoint)"} if [[ -z "${PULL_NUMBER}" ]]; then KFP_PACKAGE_PATH='git+https://github.com/kubeflow/pipelines\#egg=kfp&subdirectory=sdk/python' diff --git a/samples/v2/new_producer_consumer_param_test.py b/samples/v2/new_producer_consumer_param_test.py deleted file mode 100644 index e014ad5aa56..00000000000 --- a/samples/v2/new_producer_consumer_param_test.py +++ /dev/null @@ -1,53 +0,0 @@ -# Copyright 2021 The Kubeflow Authors -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -"""Hello world v2 engine pipeline.""" - -from __future__ import annotations - -import unittest -import kfp -from producer_consumer_param import producer_consumer_param_pipeline - -_MINUTE = 60 # seconds - - -class HelloWorldTest(unittest.TestCase): - - def test(self): - client = kfp.Client(host="http://localhost:8888") - experiment = 'An experiment with Kubeflow Pipelines v2 sample test runs.' - client.create_experiment( - name='v2_sample_test', - description=experiment - ) - - run_result = client.create_run_from_pipeline_func( - pipeline_func=producer_consumer_param_pipeline, - experiment_name=experiment, - ) - - run_response = run_result.wait_for_run_completion(5 * _MINUTE) - - client.get_run(run_response.run_id) - - from pprint import pprint - pprint(run_response.run_details) - print("Run details page URL:") - print(f"http://localhost:8080/#/runs/details/{run_response.run_id}") - - self.assertEqual(run_response.state, "SUCCEEDED") - - -if __name__ == '__main__': - unittest.main() diff --git a/samples/v2/sample_test.py b/samples/v2/sample_test.py index 8e255f887b1..d34599a3c18 100644 --- a/samples/v2/sample_test.py +++ b/samples/v2/sample_test.py @@ -50,6 +50,8 @@ def test(self): TestCase(pipeline_func=two_step_pipeline_containerized.two_step_pipeline_containerized), TestCase(pipeline_func=component_with_optional_inputs.pipeline), TestCase(pipeline_func=pipeline_with_env.pipeline_with_env), + + # The following tests are not working. Tracking issue: https://github.com/kubeflow/pipelines/issues/11053 # TestCase(pipeline_func=pipeline_with_importer.pipeline_with_importer), # TestCase(pipeline_func=pipeline_with_volume.pipeline_with_volume), # TestCase(pipeline_func=pipeline_with_secret_as_volume.pipeline_secret_volume),