# coding: utf-8 """ dts No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen) # noqa: E501 OpenAPI spec version: common-version Generated by: https://github.com/swagger-api/swagger-codegen.git """ from __future__ import absolute_import import re # noqa: F401 # python 2 and python 3 compatibility library import six import volcenginesdkcore class DTSApi(object): """NOTE: This class is auto generated by the swagger code generator program. Do not edit the class manually. Ref: https://github.com/swagger-api/swagger-codegen """ def __init__(self, api_client=None): if api_client is None: api_client = volcenginesdkcore.ApiClient() self.api_client = api_client def add_tags_to_resource(self, body, **kwargs): # noqa: E501 """add_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.add_tags_to_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.add_tags_to_resource_with_http_info(body, **kwargs) # noqa: E501 return data def add_tags_to_resource_with_http_info(self, body, **kwargs): # noqa: E501 """add_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method add_tags_to_resource" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `add_tags_to_resource`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/AddTagsToResource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='AddTagsToResourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_data_source(self, body, **kwargs): # noqa: E501 """create_data_source # 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_data_source(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateDataSourceRequest body: (required) :return: CreateDataSourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_data_source_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_data_source_with_http_info(body, **kwargs) # noqa: E501 return data def create_data_source_with_http_info(self, body, **kwargs): # noqa: E501 """create_data_source # 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_data_source_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateDataSourceRequest body: (required) :return: CreateDataSourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_data_source" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_data_source`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateDataSource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateDataSourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_subscription_group(self, body, **kwargs): # noqa: E501 """create_subscription_group # 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_subscription_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateSubscriptionGroupRequest body: (required) :return: CreateSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_subscription_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_subscription_group_with_http_info(body, **kwargs) # noqa: E501 return data def create_subscription_group_with_http_info(self, body, **kwargs): # noqa: E501 """create_subscription_group # 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_subscription_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateSubscriptionGroupRequest body: (required) :return: CreateSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_subscription_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_subscription_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateSubscriptionGroup/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateSubscriptionGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_transmission_task(self, body, **kwargs): # noqa: E501 """create_transmission_task # 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_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTransmissionTaskRequest body: (required) :return: CreateTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def create_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """create_transmission_task # 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_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTransmissionTaskRequest body: (required) :return: CreateTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def create_validation_task(self, body, **kwargs): # noqa: E501 """create_validation_task # 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_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateValidationTaskRequest body: (required) :return: CreateValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def create_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """create_validation_task # 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_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateValidationTaskRequest body: (required) :return: CreateValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method create_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `create_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CreateValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def cross_region_upsert_validation_task(self, body, **kwargs): # noqa: E501 """cross_region_upsert_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.cross_region_upsert_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param CrossRegionUpsertValidationTaskRequest body: (required) :return: CrossRegionUpsertValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.cross_region_upsert_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.cross_region_upsert_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def cross_region_upsert_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """cross_region_upsert_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.cross_region_upsert_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CrossRegionUpsertValidationTaskRequest body: (required) :return: CrossRegionUpsertValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method cross_region_upsert_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `cross_region_upsert_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CrossRegionUpsertValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CrossRegionUpsertValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_data_source(self, body, **kwargs): # noqa: E501 """delete_data_source # 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_data_source(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteDataSourceRequest body: (required) :return: DeleteDataSourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_data_source_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_data_source_with_http_info(body, **kwargs) # noqa: E501 return data def delete_data_source_with_http_info(self, body, **kwargs): # noqa: E501 """delete_data_source # 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_data_source_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteDataSourceRequest body: (required) :return: DeleteDataSourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_data_source" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_data_source`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteDataSource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteDataSourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_subscription_group(self, body, **kwargs): # noqa: E501 """delete_subscription_group # 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_subscription_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteSubscriptionGroupRequest body: (required) :return: DeleteSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_subscription_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_subscription_group_with_http_info(body, **kwargs) # noqa: E501 return data def delete_subscription_group_with_http_info(self, body, **kwargs): # noqa: E501 """delete_subscription_group # 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_subscription_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteSubscriptionGroupRequest body: (required) :return: DeleteSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_subscription_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_subscription_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteSubscriptionGroup/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteSubscriptionGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_transmission_task(self, body, **kwargs): # noqa: E501 """delete_transmission_task # 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_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTransmissionTaskRequest body: (required) :return: DeleteTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def delete_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """delete_transmission_task # 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_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTransmissionTaskRequest body: (required) :return: DeleteTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_transmission_tasks(self, body, **kwargs): # noqa: E501 """delete_transmission_tasks # 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_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTransmissionTasksRequest body: (required) :return: DeleteTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def delete_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """delete_transmission_tasks # 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_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTransmissionTasksRequest body: (required) :return: DeleteTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_validation_task(self, body, **kwargs): # noqa: E501 """delete_validation_task # 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_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteValidationTaskRequest body: (required) :return: DeleteValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def delete_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """delete_validation_task # 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_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteValidationTaskRequest body: (required) :return: DeleteValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_validation_tasks(self, body, **kwargs): # noqa: E501 """delete_validation_tasks # 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_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteValidationTasksRequest body: (required) :return: DeleteValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def delete_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """delete_validation_tasks # 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_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteValidationTasksRequest body: (required) :return: DeleteValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method delete_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `delete_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_data_source(self, body, **kwargs): # noqa: E501 """describe_data_source # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_data_source(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeDataSourceRequest body: (required) :return: DescribeDataSourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_data_source_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_data_source_with_http_info(body, **kwargs) # noqa: E501 return data def describe_data_source_with_http_info(self, body, **kwargs): # noqa: E501 """describe_data_source # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_data_source_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeDataSourceRequest body: (required) :return: DescribeDataSourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_data_source" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_data_source`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeDataSource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeDataSourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_price_differences(self, body, **kwargs): # noqa: E501 """describe_price_differences # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_price_differences(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribePriceDifferencesRequest body: (required) :return: DescribePriceDifferencesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_price_differences_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_price_differences_with_http_info(body, **kwargs) # noqa: E501 return data def describe_price_differences_with_http_info(self, body, **kwargs): # noqa: E501 """describe_price_differences # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_price_differences_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribePriceDifferencesRequest body: (required) :return: DescribePriceDifferencesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_price_differences" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_price_differences`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribePriceDifferences/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribePriceDifferencesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_subscription_group(self, body, **kwargs): # noqa: E501 """describe_subscription_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_subscription_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionGroupRequest body: (required) :return: DescribeSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_subscription_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_subscription_group_with_http_info(body, **kwargs) # noqa: E501 return data def describe_subscription_group_with_http_info(self, body, **kwargs): # noqa: E501 """describe_subscription_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_subscription_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionGroupRequest body: (required) :return: DescribeSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_subscription_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_subscription_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeSubscriptionGroup/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeSubscriptionGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_subscription_group_progress(self, body, **kwargs): # noqa: E501 """describe_subscription_group_progress # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_subscription_group_progress(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionGroupProgressRequest body: (required) :return: DescribeSubscriptionGroupProgressResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_subscription_group_progress_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_subscription_group_progress_with_http_info(body, **kwargs) # noqa: E501 return data def describe_subscription_group_progress_with_http_info(self, body, **kwargs): # noqa: E501 """describe_subscription_group_progress # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_subscription_group_progress_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionGroupProgressRequest body: (required) :return: DescribeSubscriptionGroupProgressResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_subscription_group_progress" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_subscription_group_progress`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeSubscriptionGroupProgress/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeSubscriptionGroupProgressResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_subscription_groups(self, body, **kwargs): # noqa: E501 """describe_subscription_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_subscription_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionGroupsRequest body: (required) :return: DescribeSubscriptionGroupsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_subscription_groups_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_subscription_groups_with_http_info(body, **kwargs) # noqa: E501 return data def describe_subscription_groups_with_http_info(self, body, **kwargs): # noqa: E501 """describe_subscription_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_subscription_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSubscriptionGroupsRequest body: (required) :return: DescribeSubscriptionGroupsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_subscription_groups" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_subscription_groups`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeSubscriptionGroups/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeSubscriptionGroupsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_supported_validation_types(self, body, **kwargs): # noqa: E501 """describe_supported_validation_types # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_supported_validation_types(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSupportedValidationTypesRequest body: (required) :return: DescribeSupportedValidationTypesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_supported_validation_types_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_supported_validation_types_with_http_info(body, **kwargs) # noqa: E501 return data def describe_supported_validation_types_with_http_info(self, body, **kwargs): # noqa: E501 """describe_supported_validation_types # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_supported_validation_types_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSupportedValidationTypesRequest body: (required) :return: DescribeSupportedValidationTypesResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_supported_validation_types" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_supported_validation_types`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeSupportedValidationTypes/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeSupportedValidationTypesResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_tags_by_resource(self, body, **kwargs): # noqa: E501 """describe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_tags_by_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_tags_by_resource_with_http_info(body, **kwargs) # noqa: E501 return data def describe_tags_by_resource_with_http_info(self, body, **kwargs): # noqa: E501 """describe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_tags_by_resource" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_tags_by_resource`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTagsByResource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTagsByResourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_transmission_task_info(self, body, **kwargs): # noqa: E501 """describe_transmission_task_info # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_transmission_task_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTransmissionTaskInfoRequest body: (required) :return: DescribeTransmissionTaskInfoResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_transmission_task_info_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_transmission_task_info_with_http_info(body, **kwargs) # noqa: E501 return data def describe_transmission_task_info_with_http_info(self, body, **kwargs): # noqa: E501 """describe_transmission_task_info # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_transmission_task_info_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTransmissionTaskInfoRequest body: (required) :return: DescribeTransmissionTaskInfoResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_transmission_task_info" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_transmission_task_info`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTransmissionTaskInfo/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTransmissionTaskInfoResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_transmission_task_progress(self, body, **kwargs): # noqa: E501 """describe_transmission_task_progress # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_transmission_task_progress(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTransmissionTaskProgressRequest body: (required) :return: DescribeTransmissionTaskProgressResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_transmission_task_progress_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_transmission_task_progress_with_http_info(body, **kwargs) # noqa: E501 return data def describe_transmission_task_progress_with_http_info(self, body, **kwargs): # noqa: E501 """describe_transmission_task_progress # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_transmission_task_progress_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTransmissionTaskProgressRequest body: (required) :return: DescribeTransmissionTaskProgressResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_transmission_task_progress" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_transmission_task_progress`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTransmissionTaskProgress/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTransmissionTaskProgressResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_transmission_tasks(self, body, **kwargs): # noqa: E501 """describe_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTransmissionTasksRequest body: (required) :return: DescribeTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def describe_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """describe_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTransmissionTasksRequest body: (required) :return: DescribeTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_validation_task_info(self, body, **kwargs): # noqa: E501 """describe_validation_task_info # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_validation_task_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeValidationTaskInfoRequest body: (required) :return: DescribeValidationTaskInfoResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_validation_task_info_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_validation_task_info_with_http_info(body, **kwargs) # noqa: E501 return data def describe_validation_task_info_with_http_info(self, body, **kwargs): # noqa: E501 """describe_validation_task_info # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_validation_task_info_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeValidationTaskInfoRequest body: (required) :return: DescribeValidationTaskInfoResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_validation_task_info" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_validation_task_info`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeValidationTaskInfo/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeValidationTaskInfoResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_validation_task_result(self, body, **kwargs): # noqa: E501 """describe_validation_task_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_validation_task_result(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeValidationTaskResultRequest body: (required) :return: DescribeValidationTaskResultResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_validation_task_result_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_validation_task_result_with_http_info(body, **kwargs) # noqa: E501 return data def describe_validation_task_result_with_http_info(self, body, **kwargs): # noqa: E501 """describe_validation_task_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_validation_task_result_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeValidationTaskResultRequest body: (required) :return: DescribeValidationTaskResultResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_validation_task_result" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_validation_task_result`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeValidationTaskResult/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeValidationTaskResultResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def describe_validation_tasks(self, body, **kwargs): # noqa: E501 """describe_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeValidationTasksRequest body: (required) :return: DescribeValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def describe_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """describe_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeValidationTasksRequest body: (required) :return: DescribeValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method describe_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `describe_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DescribeValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def download_validation_task_result(self, body, **kwargs): # noqa: E501 """download_validation_task_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.download_validation_task_result(body, async_req=True) >>> result = thread.get() :param async_req bool :param DownloadValidationTaskResultRequest body: (required) :return: DownloadValidationTaskResultResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.download_validation_task_result_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.download_validation_task_result_with_http_info(body, **kwargs) # noqa: E501 return data def download_validation_task_result_with_http_info(self, body, **kwargs): # noqa: E501 """download_validation_task_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.download_validation_task_result_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DownloadValidationTaskResultRequest body: (required) :return: DownloadValidationTaskResultResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method download_validation_task_result" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `download_validation_task_result`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DownloadValidationTaskResult/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DownloadValidationTaskResultResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def generate_validation_result_file(self, body, **kwargs): # noqa: E501 """generate_validation_result_file # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.generate_validation_result_file(body, async_req=True) >>> result = thread.get() :param async_req bool :param GenerateValidationResultFileRequest body: (required) :return: GenerateValidationResultFileResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.generate_validation_result_file_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.generate_validation_result_file_with_http_info(body, **kwargs) # noqa: E501 return data def generate_validation_result_file_with_http_info(self, body, **kwargs): # noqa: E501 """generate_validation_result_file # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.generate_validation_result_file_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GenerateValidationResultFileRequest body: (required) :return: GenerateValidationResultFileResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method generate_validation_result_file" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `generate_validation_result_file`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GenerateValidationResultFile/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GenerateValidationResultFileResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def get_db_table_diff_details(self, body, **kwargs): # noqa: E501 """get_db_table_diff_details # 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_db_table_diff_details(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDBTableDiffDetailsRequest body: (required) :return: GetDBTableDiffDetailsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_db_table_diff_details_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_db_table_diff_details_with_http_info(body, **kwargs) # noqa: E501 return data def get_db_table_diff_details_with_http_info(self, body, **kwargs): # noqa: E501 """get_db_table_diff_details # 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_db_table_diff_details_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDBTableDiffDetailsRequest body: (required) :return: GetDBTableDiffDetailsResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method get_db_table_diff_details" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `get_db_table_diff_details`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetDBTableDiffDetails/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetDBTableDiffDetailsResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def list_data_source(self, body, **kwargs): # noqa: E501 """list_data_source # 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_data_source(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListDataSourceRequest body: (required) :return: ListDataSourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_data_source_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_data_source_with_http_info(body, **kwargs) # noqa: E501 return data def list_data_source_with_http_info(self, body, **kwargs): # noqa: E501 """list_data_source # 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_data_source_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListDataSourceRequest body: (required) :return: ListDataSourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method list_data_source" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `list_data_source`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ListDataSource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListDataSourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_data_source(self, body, **kwargs): # noqa: E501 """modify_data_source # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_data_source(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyDataSourceRequest body: (required) :return: ModifyDataSourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_data_source_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_data_source_with_http_info(body, **kwargs) # noqa: E501 return data def modify_data_source_with_http_info(self, body, **kwargs): # noqa: E501 """modify_data_source # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_data_source_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyDataSourceRequest body: (required) :return: ModifyDataSourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_data_source" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_data_source`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyDataSource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyDataSourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_instance_order(self, body, **kwargs): # noqa: E501 """modify_instance_order # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_order(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceOrderRequest body: (required) :return: ModifyInstanceOrderResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_instance_order_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_instance_order_with_http_info(body, **kwargs) # noqa: E501 return data def modify_instance_order_with_http_info(self, body, **kwargs): # noqa: E501 """modify_instance_order # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_order_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceOrderRequest body: (required) :return: ModifyInstanceOrderResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_instance_order" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_instance_order`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyInstanceOrder/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyInstanceOrderResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_transmission_task(self, body, **kwargs): # noqa: E501 """modify_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTransmissionTaskRequest body: (required) :return: ModifyTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def modify_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """modify_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTransmissionTaskRequest body: (required) :return: ModifyTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def modify_validation_task(self, body, **kwargs): # noqa: E501 """modify_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyValidationTaskRequest body: (required) :return: ModifyValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def modify_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """modify_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyValidationTaskRequest body: (required) :return: ModifyValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method modify_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `modify_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ModifyValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def remove_tags_from_resource(self, body, **kwargs): # noqa: E501 """remove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.remove_tags_from_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.remove_tags_from_resource_with_http_info(body, **kwargs) # noqa: E501 return data def remove_tags_from_resource_with_http_info(self, body, **kwargs): # noqa: E501 """remove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method remove_tags_from_resource" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `remove_tags_from_resource`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/RemoveTagsFromResource/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='RemoveTagsFromResourceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def resume_transmission_task(self, body, **kwargs): # noqa: E501 """resume_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeTransmissionTaskRequest body: (required) :return: ResumeTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.resume_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.resume_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def resume_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """resume_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeTransmissionTaskRequest body: (required) :return: ResumeTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method resume_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `resume_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ResumeTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ResumeTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def resume_transmission_tasks(self, body, **kwargs): # noqa: E501 """resume_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeTransmissionTasksRequest body: (required) :return: ResumeTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.resume_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.resume_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def resume_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """resume_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeTransmissionTasksRequest body: (required) :return: ResumeTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method resume_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `resume_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ResumeTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ResumeTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def resume_validation_task(self, body, **kwargs): # noqa: E501 """resume_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeValidationTaskRequest body: (required) :return: ResumeValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.resume_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.resume_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def resume_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """resume_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeValidationTaskRequest body: (required) :return: ResumeValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method resume_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `resume_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ResumeValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ResumeValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def resume_validation_tasks(self, body, **kwargs): # noqa: E501 """resume_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeValidationTasksRequest body: (required) :return: ResumeValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.resume_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.resume_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def resume_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """resume_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resume_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResumeValidationTasksRequest body: (required) :return: ResumeValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method resume_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `resume_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ResumeValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ResumeValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def retry_transmission_task(self, body, **kwargs): # noqa: E501 """retry_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryTransmissionTaskRequest body: (required) :return: RetryTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.retry_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.retry_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def retry_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """retry_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryTransmissionTaskRequest body: (required) :return: RetryTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method retry_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `retry_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/RetryTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='RetryTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def retry_transmission_tasks(self, body, **kwargs): # noqa: E501 """retry_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryTransmissionTasksRequest body: (required) :return: RetryTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.retry_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.retry_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def retry_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """retry_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryTransmissionTasksRequest body: (required) :return: RetryTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method retry_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `retry_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/RetryTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='RetryTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def retry_validation_task(self, body, **kwargs): # noqa: E501 """retry_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryValidationTaskRequest body: (required) :return: RetryValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.retry_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.retry_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def retry_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """retry_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryValidationTaskRequest body: (required) :return: RetryValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method retry_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `retry_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/RetryValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='RetryValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def retry_validation_tasks(self, body, **kwargs): # noqa: E501 """retry_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryValidationTasksRequest body: (required) :return: RetryValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.retry_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.retry_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def retry_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """retry_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.retry_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RetryValidationTasksRequest body: (required) :return: RetryValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method retry_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `retry_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/RetryValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='RetryValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def spawn_swimming_lane(self, body, **kwargs): # noqa: E501 """spawn_swimming_lane # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.spawn_swimming_lane(body, async_req=True) >>> result = thread.get() :param async_req bool :param SpawnSwimmingLaneRequest body: (required) :return: SpawnSwimmingLaneResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.spawn_swimming_lane_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.spawn_swimming_lane_with_http_info(body, **kwargs) # noqa: E501 return data def spawn_swimming_lane_with_http_info(self, body, **kwargs): # noqa: E501 """spawn_swimming_lane # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.spawn_swimming_lane_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SpawnSwimmingLaneRequest body: (required) :return: SpawnSwimmingLaneResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method spawn_swimming_lane" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `spawn_swimming_lane`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/SpawnSwimmingLane/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SpawnSwimmingLaneResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def start_transmission_task(self, body, **kwargs): # noqa: E501 """start_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartTransmissionTaskRequest body: (required) :return: StartTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.start_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.start_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def start_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """start_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartTransmissionTaskRequest body: (required) :return: StartTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method start_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `start_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StartTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StartTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def start_transmission_tasks(self, body, **kwargs): # noqa: E501 """start_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartTransmissionTasksRequest body: (required) :return: StartTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.start_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.start_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def start_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """start_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartTransmissionTasksRequest body: (required) :return: StartTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method start_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `start_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StartTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StartTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def start_validation_task(self, body, **kwargs): # noqa: E501 """start_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartValidationTaskRequest body: (required) :return: StartValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.start_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.start_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def start_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """start_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartValidationTaskRequest body: (required) :return: StartValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method start_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `start_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StartValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StartValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def start_validation_tasks(self, body, **kwargs): # noqa: E501 """start_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartValidationTasksRequest body: (required) :return: StartValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.start_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.start_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def start_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """start_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartValidationTasksRequest body: (required) :return: StartValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method start_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `start_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StartValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StartValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def stop_transmission_task(self, body, **kwargs): # noqa: E501 """stop_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopTransmissionTaskRequest body: (required) :return: StopTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stop_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stop_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def stop_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """stop_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopTransmissionTaskRequest body: (required) :return: StopTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method stop_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `stop_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StopTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StopTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def stop_transmission_tasks(self, body, **kwargs): # noqa: E501 """stop_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopTransmissionTasksRequest body: (required) :return: StopTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stop_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stop_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def stop_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """stop_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopTransmissionTasksRequest body: (required) :return: StopTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method stop_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `stop_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StopTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StopTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def stop_validation_task(self, body, **kwargs): # noqa: E501 """stop_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopValidationTaskRequest body: (required) :return: StopValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stop_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stop_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def stop_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """stop_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopValidationTaskRequest body: (required) :return: StopValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method stop_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `stop_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StopValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StopValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def stop_validation_tasks(self, body, **kwargs): # noqa: E501 """stop_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopValidationTasksRequest body: (required) :return: StopValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stop_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stop_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def stop_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """stop_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopValidationTasksRequest body: (required) :return: StopValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method stop_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `stop_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StopValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StopValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def suspend_transmission_task(self, body, **kwargs): # noqa: E501 """suspend_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_transmission_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendTransmissionTaskRequest body: (required) :return: SuspendTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.suspend_transmission_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.suspend_transmission_task_with_http_info(body, **kwargs) # noqa: E501 return data def suspend_transmission_task_with_http_info(self, body, **kwargs): # noqa: E501 """suspend_transmission_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_transmission_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendTransmissionTaskRequest body: (required) :return: SuspendTransmissionTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method suspend_transmission_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `suspend_transmission_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/SuspendTransmissionTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SuspendTransmissionTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def suspend_transmission_tasks(self, body, **kwargs): # noqa: E501 """suspend_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_transmission_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendTransmissionTasksRequest body: (required) :return: SuspendTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.suspend_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.suspend_transmission_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def suspend_transmission_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """suspend_transmission_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_transmission_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendTransmissionTasksRequest body: (required) :return: SuspendTransmissionTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method suspend_transmission_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `suspend_transmission_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/SuspendTransmissionTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SuspendTransmissionTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def suspend_validation_task(self, body, **kwargs): # noqa: E501 """suspend_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_validation_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendValidationTaskRequest body: (required) :return: SuspendValidationTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.suspend_validation_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.suspend_validation_task_with_http_info(body, **kwargs) # noqa: E501 return data def suspend_validation_task_with_http_info(self, body, **kwargs): # noqa: E501 """suspend_validation_task # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_validation_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendValidationTaskRequest body: (required) :return: SuspendValidationTaskResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method suspend_validation_task" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `suspend_validation_task`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/SuspendValidationTask/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SuspendValidationTaskResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def suspend_validation_tasks(self, body, **kwargs): # noqa: E501 """suspend_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_validation_tasks(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendValidationTasksRequest body: (required) :return: SuspendValidationTasksResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.suspend_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.suspend_validation_tasks_with_http_info(body, **kwargs) # noqa: E501 return data def suspend_validation_tasks_with_http_info(self, body, **kwargs): # noqa: E501 """suspend_validation_tasks # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.suspend_validation_tasks_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SuspendValidationTasksRequest body: (required) :return: SuspendValidationTasksResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method suspend_validation_tasks" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `suspend_validation_tasks`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/SuspendValidationTasks/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SuspendValidationTasksResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def update_subscription_group(self, body, **kwargs): # noqa: E501 """update_subscription_group # 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_subscription_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateSubscriptionGroupRequest body: (required) :return: UpdateSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_subscription_group_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_subscription_group_with_http_info(body, **kwargs) # noqa: E501 return data def update_subscription_group_with_http_info(self, body, **kwargs): # noqa: E501 """update_subscription_group # 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_subscription_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateSubscriptionGroupRequest body: (required) :return: UpdateSubscriptionGroupResponse If the method is called asynchronously, returns the request thread. """ all_params = ['body'] # noqa: E501 all_params.append('async_req') all_params.append('_return_http_data_only') all_params.append('_preload_content') all_params.append('_request_timeout') params = locals() for key, val in six.iteritems(params['kwargs']): if key not in all_params: raise TypeError( "Got an unexpected keyword argument '%s'" " to method update_subscription_group" % key ) params[key] = val del params['kwargs'] # verify the required parameter 'body' is set if self.api_client.client_side_validation and ('body' not in params or params['body'] is None): # noqa: E501 raise ValueError("Missing the required parameter `body` when calling `update_subscription_group`") # noqa: E501 collection_formats = {} path_params = {} query_params = [] header_params = {} form_params = [] local_var_files = {} body_params = None if 'body' in params: body_params = params['body'] # HTTP header `Accept` header_params['Accept'] = self.api_client.select_header_accept( ['application/json']) # noqa: E501 # HTTP header `Content-Type` header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501 ['application/json']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/UpdateSubscriptionGroup/2022-10-01/dts/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateSubscriptionGroupResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats)