| # 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 ModelVersionApi(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 create_model_version(self, **kwargs): # noqa: E501 |
| """Create a model version instance # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.create_model_version(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str base_dir: |
| :param ModelVersionEntity model_version_entity: |
| :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.create_model_version_with_http_info(**kwargs) # noqa: E501 |
| |
| def create_model_version_with_http_info(self, **kwargs): # noqa: E501 |
| """Create a model version instance # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.create_model_version_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str base_dir: |
| :param ModelVersionEntity model_version_entity: |
| :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 = ['base_dir', 'model_version_entity'] |
| 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 create_model_version" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| query_params = [] |
| if 'base_dir' in local_var_params and local_var_params['base_dir'] is not None: # noqa: E501 |
| query_params.append(('baseDir', local_var_params['base_dir'])) # noqa: E501 |
| |
| header_params = {} |
| |
| form_params = [] |
| local_var_files = {} |
| |
| body_params = None |
| if 'model_version_entity' in local_var_params: |
| body_params = local_var_params['model_version_entity'] |
| # 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/model-version', |
| 'POST', |
| 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 create_model_version_tag(self, **kwargs): # noqa: E501 |
| """Create a model version tag instance # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.create_model_version_tag(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: |
| :param str version: |
| :param str tag: |
| :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.create_model_version_tag_with_http_info(**kwargs) # noqa: E501 |
| |
| def create_model_version_tag_with_http_info(self, **kwargs): # noqa: E501 |
| """Create a model version tag instance # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.create_model_version_tag_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: |
| :param str version: |
| :param str tag: |
| :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 = ['name', 'version', 'tag'] |
| 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 create_model_version_tag" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| query_params = [] |
| if 'name' in local_var_params and local_var_params['name'] is not None: # noqa: E501 |
| query_params.append(('name', local_var_params['name'])) # noqa: E501 |
| if 'version' in local_var_params and local_var_params['version'] is not None: # noqa: E501 |
| query_params.append(('version', local_var_params['version'])) # noqa: E501 |
| if 'tag' in local_var_params and local_var_params['tag'] is not None: # noqa: E501 |
| query_params.append(('tag', local_var_params['tag'])) # 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/model-version/tag', |
| 'POST', |
| 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 delete_model_version(self, name, version, **kwargs): # noqa: E501 |
| """Delete the model version # 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_model_version(name, version, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: (required) |
| :param int version: (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_model_version_with_http_info(name, version, **kwargs) # noqa: E501 |
| |
| def delete_model_version_with_http_info(self, name, version, **kwargs): # noqa: E501 |
| """Delete the model version # 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_model_version_with_http_info(name, version, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: (required) |
| :param int version: (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 = ['name', 'version'] |
| 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_model_version" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| # verify the required parameter 'name' is set |
| if self.api_client.client_side_validation and ( |
| 'name' not in local_var_params or local_var_params['name'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `name` when calling `delete_model_version`" |
| ) # noqa: E501 |
| # verify the required parameter 'version' is set |
| if self.api_client.client_side_validation and ( |
| 'version' not in local_var_params or local_var_params['version'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `version` when calling `delete_model_version`" |
| ) # noqa: E501 |
| |
| collection_formats = {} |
| |
| path_params = {} |
| if 'name' in local_var_params: |
| path_params['name'] = local_var_params['name'] # noqa: E501 |
| if 'version' in local_var_params: |
| path_params['version'] = local_var_params['version'] # 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/model-version/{name}/{version}', |
| '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 delete_model_version_tag(self, **kwargs): # noqa: E501 |
| """Delete a model version tag instance # 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_model_version_tag(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: |
| :param str version: |
| :param str tag: |
| :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_model_version_tag_with_http_info(**kwargs) # noqa: E501 |
| |
| def delete_model_version_tag_with_http_info(self, **kwargs): # noqa: E501 |
| """Delete a model version tag instance # 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_model_version_tag_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: |
| :param str version: |
| :param str tag: |
| :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 = ['name', 'version', 'tag'] |
| 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_model_version_tag" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| query_params = [] |
| if 'name' in local_var_params and local_var_params['name'] is not None: # noqa: E501 |
| query_params.append(('name', local_var_params['name'])) # noqa: E501 |
| if 'version' in local_var_params and local_var_params['version'] is not None: # noqa: E501 |
| query_params.append(('version', local_var_params['version'])) # noqa: E501 |
| if 'tag' in local_var_params and local_var_params['tag'] is not None: # noqa: E501 |
| query_params.append(('tag', local_var_params['tag'])) # 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/model-version/tag', |
| '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 get_model_version(self, name, version, **kwargs): # noqa: E501 |
| """Get detailed info about the model version # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.get_model_version(name, version, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: (required) |
| :param int version: (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.get_model_version_with_http_info(name, version, **kwargs) # noqa: E501 |
| |
| def get_model_version_with_http_info(self, name, version, **kwargs): # noqa: E501 |
| """Get detailed info about the model version # noqa: E501 |
| |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.get_model_version_with_http_info(name, version, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: (required) |
| :param int version: (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 = ['name', 'version'] |
| 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 get_model_version" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| # verify the required parameter 'name' is set |
| if self.api_client.client_side_validation and ( |
| 'name' not in local_var_params or local_var_params['name'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `name` when calling `get_model_version`" |
| ) # noqa: E501 |
| # verify the required parameter 'version' is set |
| if self.api_client.client_side_validation and ( |
| 'version' not in local_var_params or local_var_params['version'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `version` when calling `get_model_version`" |
| ) # noqa: E501 |
| |
| collection_formats = {} |
| |
| path_params = {} |
| if 'name' in local_var_params: |
| path_params['name'] = local_var_params['name'] # noqa: E501 |
| if 'version' in local_var_params: |
| path_params['version'] = local_var_params['version'] # 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/model-version/{name}/{version}', |
| '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 list_model_versions(self, name, **kwargs): # noqa: E501 |
| """List model versions # 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_model_versions(name, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: (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.list_model_versions_with_http_info(name, **kwargs) # noqa: E501 |
| |
| def list_model_versions_with_http_info(self, name, **kwargs): # noqa: E501 |
| """List model versions # 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_model_versions_with_http_info(name, async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param str name: (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 = ['name'] |
| 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_model_versions" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| # verify the required parameter 'name' is set |
| if self.api_client.client_side_validation and ( |
| 'name' not in local_var_params or local_var_params['name'] is None # noqa: E501 |
| ): # noqa: E501 |
| raise ApiValueError( |
| "Missing the required parameter `name` when calling `list_model_versions`" |
| ) # noqa: E501 |
| |
| collection_formats = {} |
| |
| path_params = {} |
| if 'name' in local_var_params: |
| path_params['name'] = local_var_params['name'] # 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/model-version/{name}', |
| '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 ping1(self, **kwargs): # noqa: E501 |
| """Ping submarine server # noqa: E501 |
| |
| Return the Pong message for test the connectivity # noqa: E501 |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.ping1(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :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: str |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| kwargs['_return_http_data_only'] = True |
| return self.ping1_with_http_info(**kwargs) # noqa: E501 |
| |
| def ping1_with_http_info(self, **kwargs): # noqa: E501 |
| """Ping submarine server # noqa: E501 |
| |
| Return the Pong message for test the connectivity # noqa: E501 |
| This method makes a synchronous HTTP request by default. To make an |
| asynchronous HTTP request, please pass async_req=True |
| >>> thread = api.ping1_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :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(str, status_code(int), headers(HTTPHeaderDict)) |
| If the method is called asynchronously, |
| returns the request thread. |
| """ |
| |
| local_var_params = locals() |
| |
| all_params = [] |
| 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 ping1" % key) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| 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/model-version/ping', |
| 'GET', |
| path_params, |
| query_params, |
| header_params, |
| body=body_params, |
| post_params=form_params, |
| files=local_var_files, |
| response_type='str', # 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_model_version(self, **kwargs): # noqa: E501 |
| """Update the model version # 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_model_version(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param ModelVersionEntity model_version_entity: |
| :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_model_version_with_http_info(**kwargs) # noqa: E501 |
| |
| def update_model_version_with_http_info(self, **kwargs): # noqa: E501 |
| """Update the model version # 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_model_version_with_http_info(async_req=True) |
| >>> result = thread.get() |
| |
| :param async_req bool: execute request asynchronously |
| :param ModelVersionEntity model_version_entity: |
| :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 = ['model_version_entity'] |
| 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_model_version" % key |
| ) |
| local_var_params[key] = val |
| del local_var_params['kwargs'] |
| |
| collection_formats = {} |
| |
| path_params = {} |
| |
| query_params = [] |
| |
| header_params = {} |
| |
| form_params = [] |
| local_var_files = {} |
| |
| body_params = None |
| if 'model_version_entity' in local_var_params: |
| body_params = local_var_params['model_version_entity'] |
| # 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/model-version', |
| '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, |
| ) |
