| # Licensed to the Apache Software Foundation (ASF) under one or more |
| # contributor license agreements. See the NOTICE file distributed with |
| # this work for additional information regarding copyright ownership. |
| # The ASF licenses this file to You 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. |
| |
| # coding: utf-8 |
| |
| """ |
| Submarine API |
| |
| The Submarine REST API allows you to access Submarine resources such as, experiments, environments and notebooks. The API is hosted under the /v1 path on the Submarine server. For example, to list experiments on a server hosted at http://localhost:8080, access http://localhost:8080/api/v1/experiment/ # noqa: E501 |
| |
| The version of the OpenAPI document: 0.8.0 |
| Contact: dev@submarine.apache.org |
| Generated by: https://openapi-generator.tech |
| """ |
| |
| |
| from __future__ import absolute_import |
| |
| import re # noqa: F401 |
| |
| # python 2 and python 3 compatibility library |
| import six |
| |
| from submarine.client.api_client import ApiClient |
| from submarine.client.exceptions import ApiTypeError, ApiValueError # noqa: F401 |
| |
| |
| class ExperimentTemplatesApi(object): |
| """NOTE: This class is auto generated by OpenAPI Generator |
| Ref: https://openapi-generator.tech |
| |
| Do not edit the class manually. |
| """ |
| |
| def __init__(self, api_client=None): |
| if api_client is None: |
| api_client = ApiClient() |
| self.api_client = api_client |
| |
| def delete_experiment_template(self, id, **kwargs): # noqa: E501 |
| """Delete the experimentTemplate # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.delete_experiment_template(id, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str id: (required) |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: JsonResponse |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| kwargs['_return_http_data_only'] = True |
| return self.delete_experiment_template_with_http_info(id, **kwargs) # noqa: E501 |
| |
| def delete_experiment_template_with_http_info(self, id, **kwargs): # noqa: E501 |
| """Delete the experimentTemplate # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.delete_experiment_template_with_http_info(id, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str id: (required) |
| :param _return_http_data_only: response data without head status code |
| and headers |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: tuple(JsonResponse, status_code(int), headers(HTTPHeaderDict)) |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| |
| local_var_params = locals() |
| |
| all_params = ['id'] |
| all_params.extend(['async_req', '_return_http_data_only', '_preload_content', '_request_timeout']) |
| |
| for key, val in six.iteritems(local_var_params['kwargs']): |
| if key not in all_params: |
| raise ApiTypeError( |
| "Got an unexpected keyword argument '%s' to method delete_experiment_template" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| # verify the required parameter 'id' is set |
| if self.api_client.client_side_validation and ( |
| 'id' not in local_var_params or local_var_params['id'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `id` when calling `delete_experiment_template`" |
| ) # noqa: E501 |
| |
| collection_formats = {} |
| |
| path_params = {} |
| if 'id' in local_var_params: |
| path_params['id'] = local_var_params['id'] # noqa: E501 |
| |
| query_params = [] |
| |
| header_params = {} |
| |
| form_params = [] |
| local_var_files = {} |
| |
| body_params = None |
| # HTTP header `Accept` |
| header_params['Accept'] = self.api_client.select_header_accept( |
| ['application/json; charset=utf-8'] |
| ) # noqa: E501 |
| |
| # Authentication setting |
| auth_settings = [] # noqa: E501 |
| |
| return self.api_client.call_api( |
| '/v1/template/{id}', |
| 'DELETE', |
| path_params, |
| query_params, |
| header_params, |
| body=body_params, |
| post_params=form_params, |
| files=local_var_files, |
| response_type='JsonResponse', # noqa: E501 |
| auth_settings=auth_settings, |
| async_req=local_var_params.get('async_req'), |
| _return_http_data_only=local_var_params.get('_return_http_data_only'), # noqa: E501 |
| _preload_content=local_var_params.get('_preload_content', True), |
| _request_timeout=local_var_params.get('_request_timeout'), |
| collection_formats=collection_formats, |
| ) |
| |
| def list_experiment_template(self, **kwargs): # noqa: E501 |
| """List of ExperimentTemplates # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.list_experiment_template(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str status: |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: JsonResponse |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| kwargs['_return_http_data_only'] = True |
| return self.list_experiment_template_with_http_info(**kwargs) # noqa: E501 |
| |
| def list_experiment_template_with_http_info(self, **kwargs): # noqa: E501 |
| """List of ExperimentTemplates # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.list_experiment_template_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str status: |
| :param _return_http_data_only: response data without head status code |
| and headers |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: tuple(JsonResponse, status_code(int), headers(HTTPHeaderDict)) |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| |
| local_var_params = locals() |
| |
| all_params = ['status'] |
| all_params.extend(['async_req', '_return_http_data_only', '_preload_content', '_request_timeout']) |
| |
| for key, val in six.iteritems(local_var_params['kwargs']): |
| if key not in all_params: |
| raise ApiTypeError( |
| "Got an unexpected keyword argument '%s' to method list_experiment_template" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| query_params = [] |
| if 'status' in local_var_params and local_var_params['status'] is not None: # noqa: E501 |
| query_params.append(('status', local_var_params['status'])) # noqa: E501 |
| |
| header_params = {} |
| |
| form_params = [] |
| local_var_files = {} |
| |
| body_params = None |
| # HTTP header `Accept` |
| header_params['Accept'] = self.api_client.select_header_accept( |
| ['application/json; charset=utf-8'] |
| ) # noqa: E501 |
| |
| # Authentication setting |
| auth_settings = [] # noqa: E501 |
| |
| return self.api_client.call_api( |
| '/v1/template', |
| 'GET', |
| path_params, |
| query_params, |
| header_params, |
| body=body_params, |
| post_params=form_params, |
| files=local_var_files, |
| response_type='JsonResponse', # noqa: E501 |
| auth_settings=auth_settings, |
| async_req=local_var_params.get('async_req'), |
| _return_http_data_only=local_var_params.get('_return_http_data_only'), # noqa: E501 |
| _preload_content=local_var_params.get('_preload_content', True), |
| _request_timeout=local_var_params.get('_request_timeout'), |
| collection_formats=collection_formats, |
| ) |
| |
| def update_experiment_template(self, id, **kwargs): # noqa: E501 |
| """Update the experimentTemplate with job spec # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.update_experiment_template(id, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str id: (required) |
| :param ExperimentTemplateSpec experiment_template_spec: |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: JsonResponse |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| kwargs['_return_http_data_only'] = True |
| return self.update_experiment_template_with_http_info(id, **kwargs) # noqa: E501 |
| |
| def update_experiment_template_with_http_info(self, id, **kwargs): # noqa: E501 |
| """Update the experimentTemplate with job spec # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.update_experiment_template_with_http_info(id, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str id: (required) |
| :param ExperimentTemplateSpec experiment_template_spec: |
| :param _return_http_data_only: response data without head status code |
| and headers |
| :param _preload_content: if False, the urllib3.HTTPResponse object will |
| be returned without reading/decoding response |
| data. Default is True. |
| :param _request_timeout: timeout setting for this request. If one |
| number provided, it will be total request |
| timeout. It can also be a pair (tuple) of |
| (connection, read) timeouts. |
| :return: tuple(JsonResponse, status_code(int), headers(HTTPHeaderDict)) |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| |
| local_var_params = locals() |
| |
| all_params = ['id', 'experiment_template_spec'] |
| all_params.extend(['async_req', '_return_http_data_only', '_preload_content', '_request_timeout']) |
| |
| for key, val in six.iteritems(local_var_params['kwargs']): |
| if key not in all_params: |
| raise ApiTypeError( |
| "Got an unexpected keyword argument '%s' to method update_experiment_template" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| # verify the required parameter 'id' is set |
| if self.api_client.client_side_validation and ( |
| 'id' not in local_var_params or local_var_params['id'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `id` when calling `update_experiment_template`" |
| ) # noqa: E501 |
| |
| collection_formats = {} |
| |
| path_params = {} |
| if 'id' in local_var_params: |
| path_params['id'] = local_var_params['id'] # noqa: E501 |
| |
| query_params = [] |
| |
| header_params = {} |
| |
| form_params = [] |
| local_var_files = {} |
| |
| body_params = None |
| if 'experiment_template_spec' in local_var_params: |
| body_params = local_var_params['experiment_template_spec'] |
| # HTTP header `Accept` |
| header_params['Accept'] = self.api_client.select_header_accept( |
| ['application/json; charset=utf-8'] |
| ) # noqa: E501 |
| |
| # HTTP header `Content-Type` |
| header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 |
| ['application/json', 'application/yaml'] |
| ) # noqa: E501 |
| |
| # Authentication setting |
| auth_settings = [] # noqa: E501 |
| |
| return self.api_client.call_api( |
| '/v1/template/{id}', |
| 'PATCH', |
| path_params, |
| query_params, |
| header_params, |
| body=body_params, |
| post_params=form_params, |
| files=local_var_files, |
| response_type='JsonResponse', # noqa: E501 |
| auth_settings=auth_settings, |
| async_req=local_var_params.get('async_req'), |
| _return_http_data_only=local_var_params.get('_return_http_data_only'), # noqa: E501 |
| _preload_content=local_var_params.get('_preload_content', True), |
| _request_timeout=local_var_params.get('_request_timeout'), |
| collection_formats=collection_formats, |
| ) |