
    ~i5a                    J    d Z ddlmZ ddlZddlZddlZ G d de          ZdS )z
    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
    )absolute_importNc                      e Zd ZdZdtdZd Zd Zd Zd Zd Z	d	 Z
d
 Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d  Z!d! Z"d" Z#d# Z$d$ Z%d% Z&d& Z'd' Z(d( Z)d) Z*d* Z+d+ Z,d, Z-d- Z.d. Z/d/ Z0d0 Z1d1 Z2d2 Z3d3 Z4d4 Z5d5 Z6d6 Z7d7 Z8d8 Z9d9 Z:d: Z;d; Z<d< Z=d= Z>d> Z?d? Z@d@ ZAdA ZBdB ZCdC ZDdD ZEdE ZFdF ZGdG ZHdH ZIdI ZJdJ ZKdK ZLdL ZMdM ZNdN ZOdO ZPdP ZQdQ ZRdR ZSdS ZTdT ZUdU ZVdV ZWdW ZXdX ZYdY ZZdZ Z[d[ Z\d\ Z]d] Z^d^ Z_d_ Z`d` Zada Zbdb Zcdc Zddd Zede Zfdf Zgdg Zhdh Zidi Zjdj Zkdk Zldl Zmdm Zndn Zodo Zpdp Zqdq Zrdr Zsds ZtdS )uDTSApizNOTE: 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
    Nc                 >    |t          j                    }|| _        d S N)volcenginesdkcore	ApiClient
api_client)selfr
   s     e/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkdts/api/dts_api.py__init__zDTSApi.__init__   s!    *466J$    c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        T_return_http_data_only	async_req)get#add_tags_to_resource_with_http_infor   bodykwargsdatas       r   add_tags_to_resourcezDTSApi.add_tags_to_resource$   ]     ,0'(::k"" 	;4;DKKFKKK=T=dMMfMMTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   _preload_content_request_timeoutr   zFGot an unexpected keyword argument '%s' to method add_tags_to_resourceNzIMissing the required parameter `body` when calling `add_tags_to_resource`application/jsonAcceptContent-TypevolcengineSignz8/AddTagsToResource/2022-10-01/dts/post/application_json/POSTAddTagsToResourceResponseT
r   post_paramsfilesresponse_typeauth_settingsr   r   r   r   collection_formatsappendlocalssix	iteritems	TypeErrorr
   client_side_validation
ValueErrorselect_header_acceptselect_header_content_typecall_apir   r   r   r   
all_paramsparamskeyvalr(   path_paramsquery_paramsheader_paramsform_paramslocal_var_filesbody_paramsr'   s                  r   r   z*DTSApi.add_tags_to_resource_with_http_info9   s    X
+&&&2333,---,---fX&677 	 	HC*$$68;<   F3KK8?1 	jvV7K7K7=f~7MhiiiV .K"&/"F"F #" #"h )-(R(R )" )"n% **''F#!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   !create_data_source_with_http_infor   s       r   create_data_sourcezDTSApi.create_data_source   ]     ,0'(::k"" 	949$II&III;T;DKKFKKTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zDGot an unexpected keyword argument '%s' to method create_data_sourceNzGMissing the required parameter `body` when calling `create_data_source`r   r   r   r    z7/CreateDataSource/2022-10-01/dts/post/application_json/r!   CreateDataSourceResponseTr#   r)   r4   s                  r   r@   z(DTSApi.create_data_source_with_http_info       X
+&&&2333,---,---fX&677 	 	HC*$$469:   F3KK8?1 	hvV7K7K7=f~7MfgggV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Ev#!4'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (create_subscription_group_with_http_infor   s       r   create_subscription_groupz DTSApi.create_subscription_group   ]     ,0'(::k"" 	@4@PPPPPBTB4RR6RRTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method create_subscription_groupNzNMissing the required parameter `body` when calling `create_subscription_group`r   r   r   r    z>/CreateSubscriptionGroup/2022-10-01/dts/post/application_json/r!   CreateSubscriptionGroupResponseTr#   r)   r4   s                  r   rG   z/DTSApi.create_subscription_group_with_http_info       X
+&&&2333,---,---fX&677 	 	HC*$$;=@A   F3KK8?1 	ovV7K7K7=f~7MmnnnV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Lf#!;'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'create_transmission_task_with_http_infor   s       r   create_transmission_taskzDTSApi.create_transmission_taskG  ]     ,0'(::k"" 	?4?OOOOOATA$QQ&QQTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method create_transmission_taskNzMMissing the required parameter `body` when calling `create_transmission_task`r   r   r   r    z=/CreateTransmissionTask/2022-10-01/dts/post/application_json/r!   CreateTransmissionTaskResponseTr#   r)   r4   s                  r   rN   z.DTSApi.create_transmission_task_with_http_info\      X
+&&&2333,---,---fX&677 	 	HC*$$:<?@   F3KK8?1 	nvV7K7K7=f~7MlmmmV .K"&/"F"F #" #"h )-(R(R )" )"n% **''KV#!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %create_validation_task_with_http_infor   s       r   create_validation_taskzDTSApi.create_validation_task  ]     ,0'(::k"" 	=4=dMMfMMM?T?OOOOTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method create_validation_taskNzKMissing the required parameter `body` when calling `create_validation_task`r   r   r   r    z;/CreateValidationTask/2022-10-01/dts/post/application_json/r!   CreateValidationTaskResponseTr#   r)   r4   s                  r   rU   z,DTSApi.create_validation_task_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$8:=>   F3KK8?1 	lvV7K7K7=f~7MjkkkV .K"&/"F"F #" #"h )-(R(R )" )"n% **''I6#!8'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a?  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.
        Tr   r   )r   2cross_region_upsert_validation_task_with_http_infor   s       r   #cross_region_upsert_validation_taskz*DTSApi.cross_region_upsert_validation_task	  _     ,0'(::k"" 	J4J4ZZSYZZZLTLT\\U[\\TKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )aN  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.
        r   r   r   r   r   r   zUGot an unexpected keyword argument '%s' to method cross_region_upsert_validation_taskNzXMissing the required parameter `body` when calling `cross_region_upsert_validation_task`r   r   r   r    zF/CrossRegionUpsertValidationTask/2022-10-01/dts/post/application_json/r!   'CrossRegionUpsertValidationTaskResponseTr#   r)   r4   s                  r   r\   z9DTSApi.cross_region_upsert_validation_task_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$EGJK   F3KK8?1 	yvV7K7K7=f~7MwxxxV .K"&/"F"F #" #"h )-(R(R )" )"n% **''TV\#!C'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   !delete_data_source_with_http_infor   s       r   delete_data_sourcezDTSApi.delete_data_sourcej  rB   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zDGot an unexpected keyword argument '%s' to method delete_data_sourceNzGMissing the required parameter `body` when calling `delete_data_source`r   r   r   r    z7/DeleteDataSource/2022-10-01/dts/post/application_json/r!   DeleteDataSourceResponseTr#   r)   r4   s                  r   rb   z(DTSApi.delete_data_source_with_http_info  rE   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (delete_subscription_group_with_http_infor   s       r   delete_subscription_groupz DTSApi.delete_subscription_group  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method delete_subscription_groupNzNMissing the required parameter `body` when calling `delete_subscription_group`r   r   r   r    z>/DeleteSubscriptionGroup/2022-10-01/dts/post/application_json/r!   DeleteSubscriptionGroupResponseTr#   r)   r4   s                  r   rg   z/DTSApi.delete_subscription_group_with_http_info  rL   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'delete_transmission_task_with_http_infor   s       r   delete_transmission_taskzDTSApi.delete_transmission_task,  rP   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method delete_transmission_taskNzMMissing the required parameter `body` when calling `delete_transmission_task`r   r   r   r    z=/DeleteTransmissionTask/2022-10-01/dts/post/application_json/r!   DeleteTransmissionTaskResponseTr#   r)   r4   s                  r   rl   z.DTSApi.delete_transmission_task_with_http_infoA  rS   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (delete_transmission_tasks_with_http_infor   s       r   delete_transmission_tasksz DTSApi.delete_transmission_tasks  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method delete_transmission_tasksNzNMissing the required parameter `body` when calling `delete_transmission_tasks`r   r   r   r    z>/DeleteTransmissionTasks/2022-10-01/dts/post/application_json/r!   DeleteTransmissionTasksResponseTr#   r)   r4   s                  r   rq   z/DTSApi.delete_transmission_tasks_with_http_info  rL   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %delete_validation_task_with_http_infor   s       r   delete_validation_taskzDTSApi.delete_validation_task  rW   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method delete_validation_taskNzKMissing the required parameter `body` when calling `delete_validation_task`r   r   r   r    z;/DeleteValidationTask/2022-10-01/dts/post/application_json/r!   DeleteValidationTaskResponseTr#   r)   r4   s                  r   rv   z,DTSApi.delete_validation_task_with_http_info  rZ   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   &delete_validation_tasks_with_http_infor   s       r   delete_validation_taskszDTSApi.delete_validation_tasksO  ]     ,0'(::k"" 	>4>tNNvNNN@T@PPPPTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a"  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.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method delete_validation_tasksNzLMissing the required parameter `body` when calling `delete_validation_tasks`r   r   r   r    z</DeleteValidationTasks/2022-10-01/dts/post/application_json/r!   DeleteValidationTasksResponseTr#   r)   r4   s                  r   r{   z-DTSApi.delete_validation_tasks_with_http_infod      X
+&&&2333,---,---fX&677 	 	HC*$$9;>?   F3KK8?1 	mvV7K7K7=f~7MklllV .K"&/"F"F #" #"h )-(R(R )" )"n% **''JF#!9'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   #describe_data_source_with_http_infor   s       r   describe_data_sourcezDTSApi.describe_data_source  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zFGot an unexpected keyword argument '%s' to method describe_data_sourceNzIMissing the required parameter `body` when calling `describe_data_source`r   r   r   r    z9/DescribeDataSource/2022-10-01/dts/post/application_json/r!   DescribeDataSourceResponseTr#   r)   r4   s                  r   r   z*DTSApi.describe_data_source_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$68;<   F3KK8?1 	jvV7K7K7=f~7MhiiiV .K"&/"F"F #" #"h )-(R(R )" )"n% **''G#!6'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   )describe_price_differences_with_http_infor   s       r   describe_price_differencesz!DTSApi.describe_price_differences  ]     ,0'(::k"" 	A4A$QQ&QQQCTCDSSFSSTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a.  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.
        r   r   r   r   r   r   zLGot an unexpected keyword argument '%s' to method describe_price_differencesNzOMissing the required parameter `body` when calling `describe_price_differences`r   r   r   r    z?/DescribePriceDifferences/2022-10-01/dts/post/application_json/r!    DescribePriceDifferencesResponseTr#   r)   r4   s                  r   r   z0DTSApi.describe_price_differences_with_http_info&      X
+&&&2333,---,---fX&677 	 	HC*$$<>AB   F3KK8?1 	pvV7K7K7=f~7MnoooV .K"&/"F"F #" #"h )-(R(R )" )"n% **''Mv#!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a#  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.
        Tr   r   )r   *describe_subscription_group_with_http_infor   s       r   describe_subscription_groupz"DTSApi.describe_subscription_groupr  ]     ,0'(::k"" 	B4B4RR6RRRDTDTTTVTTTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a2  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.
        r   r   r   r   r   r   zMGot an unexpected keyword argument '%s' to method describe_subscription_groupNzPMissing the required parameter `body` when calling `describe_subscription_group`r   r   r   r    z@/DescribeSubscriptionGroup/2022-10-01/dts/post/application_json/r!   !DescribeSubscriptionGroupResponseTr#   r)   r4   s                  r   r   z1DTSApi.describe_subscription_group_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$=?BC   F3KK8?1 	qvV7K7K7=f~7MopppV .K"&/"F"F #" #"h )-(R(R )" )"n% **''NPV#!='jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )aE  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.
        Tr   r   )r   3describe_subscription_group_progress_with_http_infor   s       r   $describe_subscription_group_progressz+DTSApi.describe_subscription_group_progress  s_     ,0'(::k"" 	K4KD[[TZ[[[MTMd]]V\]]TKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )aT  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.
        r   r   r   r   r   r   zVGot an unexpected keyword argument '%s' to method describe_subscription_group_progressNzYMissing the required parameter `body` when calling `describe_subscription_group_progress`r   r   r   r    zH/DescribeSubscriptionGroupProgress/2022-10-01/dts/post/application_json/r!   )DescribeSubscriptionGroupProgressResponseTr#   r)   r4   s                  r   r   z:DTSApi.describe_subscription_group_progress_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$FHKL   F3KK8?1 	zvV7K7K7=f~7MxyyyV .K"&/"F"F #" #"h )-(R(R )" )"n% **''VX^#!E'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a'  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.
        Tr   r   )r   +describe_subscription_groups_with_http_infor   s       r   describe_subscription_groupsz#DTSApi.describe_subscription_groups4  s]     ,0'(::k"" 	C4CDSSFSSSETEdUUfUUTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a6  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.
        r   r   r   r   r   r   zNGot an unexpected keyword argument '%s' to method describe_subscription_groupsNzQMissing the required parameter `body` when calling `describe_subscription_groups`r   r   r   r    zA/DescribeSubscriptionGroups/2022-10-01/dts/post/application_json/r!   "DescribeSubscriptionGroupsResponseTr#   r)   r4   s                  r   r   z2DTSApi.describe_subscription_groups_with_http_infoI  s    X
+&&&2333,---,---fX&677 	 	HC*$$>@CD   F3KK8?1 	rvV7K7K7=f~7MpqqqV .K"&/"F"F #" #"h )-(R(R )" )"n% **''OQW#!>'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )aA  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.
        Tr   r   )r   2describe_supported_validation_types_with_http_infor   s       r   #describe_supported_validation_typesz*DTSApi.describe_supported_validation_types  r^   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )aP  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.
        r   r   r   r   r   r   zUGot an unexpected keyword argument '%s' to method describe_supported_validation_typesNzXMissing the required parameter `body` when calling `describe_supported_validation_types`r   r   r   r    zG/DescribeSupportedValidationTypes/2022-10-01/dts/post/application_json/r!   (DescribeSupportedValidationTypesResponseTr#   r)   r4   s                  r   r   z9DTSApi.describe_supported_validation_types_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$EGJK   F3KK8?1 	yvV7K7K7=f~7MwxxxV .K"&/"F"F #" #"h )-(R(R )" )"n% **''UW]#!D'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (describe_tags_by_resource_with_http_infor   s       r   describe_tags_by_resourcez DTSApi.describe_tags_by_resource  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a(  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method describe_tags_by_resourceNzNMissing the required parameter `body` when calling `describe_tags_by_resource`r   r   r   r    z=/DescribeTagsByResource/2022-10-01/dts/post/application_json/r!   DescribeTagsByResourceResponseTr#   r)   r4   s                  r   r   z/DTSApi.describe_tags_by_resource_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$;=@A   F3KK8?1 	ovV7K7K7=f~7MmnnnV .K"&/"F"F #" #"h )-(R(R )" )"n% **''KV#!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a1  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.
        Tr   r   )r   .describe_transmission_task_info_with_http_infor   s       r   describe_transmission_task_infoz&DTSApi.describe_transmission_task_infoW  ^     ,0'(::k"" 	F4FtVVvVVVHTHXXQWXXTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a@  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.
        r   r   r   r   r   r   zQGot an unexpected keyword argument '%s' to method describe_transmission_task_infoNzTMissing the required parameter `body` when calling `describe_transmission_task_info`r   r   r   r    zC/DescribeTransmissionTaskInfo/2022-10-01/dts/post/application_json/r!   $DescribeTransmissionTaskInfoResponseTr#   r)   r4   s                  r   r   z5DTSApi.describe_transmission_task_info_with_http_infol      X
+&&&2333,---,---fX&677 	 	HC*$$ACFG   F3KK8?1 	uvV7K7K7=f~7MstttV .K"&/"F"F #" #"h )-(R(R )" )"n% **''QSY#!@'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )aA  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.
        Tr   r   )r   2describe_transmission_task_progress_with_http_infor   s       r   #describe_transmission_task_progressz*DTSApi.describe_transmission_task_progress  r^   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )aP  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.
        r   r   r   r   r   r   zUGot an unexpected keyword argument '%s' to method describe_transmission_task_progressNzXMissing the required parameter `body` when calling `describe_transmission_task_progress`r   r   r   r    zG/DescribeTransmissionTaskProgress/2022-10-01/dts/post/application_json/r!   (DescribeTransmissionTaskProgressResponseTr#   r)   r4   s                  r   r   z9DTSApi.describe_transmission_task_progress_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a#  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.
        Tr   r   )r   *describe_transmission_tasks_with_http_infor   s       r   describe_transmission_tasksz"DTSApi.describe_transmission_tasks  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a2  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.
        r   r   r   r   r   r   zMGot an unexpected keyword argument '%s' to method describe_transmission_tasksNzPMissing the required parameter `body` when calling `describe_transmission_tasks`r   r   r   r    z@/DescribeTransmissionTasks/2022-10-01/dts/post/application_json/r!   !DescribeTransmissionTasksResponseTr#   r)   r4   s                  r   r   z1DTSApi.describe_transmission_tasks_with_http_info.  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a)  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.
        Tr   r   )r   ,describe_validation_task_info_with_http_infor   s       r   describe_validation_task_infoz$DTSApi.describe_validation_task_infoz  s]     ,0'(::k"" 	D4DTTTVTTTFTFtVVvVVTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a8  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.
        r   r   r   r   r   r   zOGot an unexpected keyword argument '%s' to method describe_validation_task_infoNzRMissing the required parameter `body` when calling `describe_validation_task_info`r   r   r   r    zA/DescribeValidationTaskInfo/2022-10-01/dts/post/application_json/r!   "DescribeValidationTaskInfoResponseTr#   r)   r4   s                  r   r   z3DTSApi.describe_validation_task_info_with_http_info  s    X
+&&&2333,---,---fX&677 	 	HC*$$?ADE   F3KK8?1 	svV7K7K7=f~7MqrrrV .K"&/"F"F #" #"h )-(R(R )" )"n% **''OQW#!>'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a1  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.
        Tr   r   )r   .describe_validation_task_result_with_http_infor   s       r   describe_validation_task_resultz&DTSApi.describe_validation_task_result  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a@  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.
        r   r   r   r   r   r   zQGot an unexpected keyword argument '%s' to method describe_validation_task_resultNzTMissing the required parameter `body` when calling `describe_validation_task_result`r   r   r   r    zC/DescribeValidationTaskResult/2022-10-01/dts/post/application_json/r!   $DescribeValidationTaskResultResponseTr#   r)   r4   s                  r   r   z5DTSApi.describe_validation_task_result_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (describe_validation_tasks_with_http_infor   s       r   describe_validation_tasksz DTSApi.describe_validation_tasks<	  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method describe_validation_tasksNzNMissing the required parameter `body` when calling `describe_validation_tasks`r   r   r   r    z>/DescribeValidationTasks/2022-10-01/dts/post/application_json/r!   DescribeValidationTasksResponseTr#   r)   r4   s                  r   r   z/DTSApi.describe_validation_tasks_with_http_infoQ	  rL   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a1  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.
        Tr   r   )r   .download_validation_task_result_with_http_infor   s       r   download_validation_task_resultz&DTSApi.download_validation_task_result	  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a@  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.
        r   r   r   r   r   r   zQGot an unexpected keyword argument '%s' to method download_validation_task_resultNzTMissing the required parameter `body` when calling `download_validation_task_result`r   r   r   r    zC/DownloadValidationTaskResult/2022-10-01/dts/post/application_json/r!   $DownloadValidationTaskResultResponseTr#   r)   r4   s                  r   r   z5DTSApi.download_validation_task_result_with_http_info	  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a1  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.
        Tr   r   )r   .generate_validation_result_file_with_http_infor   s       r   generate_validation_result_filez&DTSApi.generate_validation_result_file	  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a@  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.
        r   r   r   r   r   r   zQGot an unexpected keyword argument '%s' to method generate_validation_result_fileNzTMissing the required parameter `body` when calling `generate_validation_result_file`r   r   r   r    zC/GenerateValidationResultFile/2022-10-01/dts/post/application_json/r!   $GenerateValidationResultFileResponseTr#   r)   r4   s                  r   r   z5DTSApi.generate_validation_result_file_with_http_info
  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (get_db_table_diff_details_with_http_infor   s       r   get_db_table_diff_detailsz DTSApi.get_db_table_diff_details_
  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method get_db_table_diff_detailsNzNMissing the required parameter `body` when calling `get_db_table_diff_details`r   r   r   r    z</GetDBTableDiffDetails/2022-10-01/dts/post/application_json/r!   GetDBTableDiffDetailsResponseTr#   r)   r4   s                  r   r   z/DTSApi.get_db_table_diff_details_with_http_infot
  s    X
+&&&2333,---,---fX&677 	 	HC*$$;=@A   F3KK8?1 	ovV7K7K7=f~7MmnnnV .K"&/"F"F #" #"h )-(R(R )" )"n% **''JF#!9'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   list_data_source_with_http_infor   s       r   list_data_sourcezDTSApi.list_data_source
  s]     ,0'(::k"" 	747GGGGG9T9$II&IITKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zBGot an unexpected keyword argument '%s' to method list_data_sourceNzEMissing the required parameter `body` when calling `list_data_source`r   r   r   r    z5/ListDataSource/2022-10-01/dts/post/application_json/r!   ListDataSourceResponseTr#   r)   r4   s                  r   r   z&DTSApi.list_data_source_with_http_info
  s    X
+&&&2333,---,---fX&677 	 	HC*$$2478   F3KK8?1 	fvV7K7K7=f~7MdeeeV .K"&/"F"F #" #"h )-(R(R )" )"n% **''CV#!2'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   !modify_data_source_with_http_infor   s       r   modify_data_sourcezDTSApi.modify_data_source!  rB   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zDGot an unexpected keyword argument '%s' to method modify_data_sourceNzGMissing the required parameter `body` when calling `modify_data_source`r   r   r   r    z7/ModifyDataSource/2022-10-01/dts/post/application_json/r!   ModifyDataSourceResponseTr#   r)   r4   s                  r   r   z(DTSApi.modify_data_source_with_http_info6  rE   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $modify_instance_order_with_http_infor   s       r   modify_instance_orderzDTSApi.modify_instance_order  ]     ,0'(::k"" 	<4<TLLVLLL>T>tNNvNNTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method modify_instance_orderNzJMissing the required parameter `body` when calling `modify_instance_order`r   r   r   r    z:/ModifyInstanceOrder/2022-10-01/dts/post/application_json/r!   ModifyInstanceOrderResponseTr#   r)   r4   s                  r   r   z+DTSApi.modify_instance_order_with_http_info      X
+&&&2333,---,---fX&677 	 	HC*$$79<=   F3KK8?1 	kvV7K7K7=f~7MijjjV .K"&/"F"F #" #"h )-(R(R )" )"n% **''H&#!7'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'modify_transmission_task_with_http_infor   s       r   modify_transmission_taskzDTSApi.modify_transmission_task  rP   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method modify_transmission_taskNzMMissing the required parameter `body` when calling `modify_transmission_task`r   r   r   r    z=/ModifyTransmissionTask/2022-10-01/dts/post/application_json/r!   ModifyTransmissionTaskResponseTr#   r)   r4   s                  r   r   z.DTSApi.modify_transmission_task_with_http_info  rS   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %modify_validation_task_with_http_infor   s       r   modify_validation_taskzDTSApi.modify_validation_taskD  rW   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method modify_validation_taskNzKMissing the required parameter `body` when calling `modify_validation_task`r   r   r   r    z;/ModifyValidationTask/2022-10-01/dts/post/application_json/r!   ModifyValidationTaskResponseTr#   r)   r4   s                  r   r   z,DTSApi.modify_validation_task_with_http_infoY  rZ   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (remove_tags_from_resource_with_http_infor   s       r   remove_tags_from_resourcez DTSApi.remove_tags_from_resource  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a(  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method remove_tags_from_resourceNzNMissing the required parameter `body` when calling `remove_tags_from_resource`r   r   r   r    z=/RemoveTagsFromResource/2022-10-01/dts/post/application_json/r!   RemoveTagsFromResourceResponseTr#   r)   r4   s                  r   r   z/DTSApi.remove_tags_from_resource_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'resume_transmission_task_with_http_infor   s       r   resume_transmission_taskzDTSApi.resume_transmission_task  rP   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method resume_transmission_taskNzMMissing the required parameter `body` when calling `resume_transmission_task`r   r   r   r    z=/ResumeTransmissionTask/2022-10-01/dts/post/application_json/r!   ResumeTransmissionTaskResponseTr#   r)   r4   s                  r   r   z.DTSApi.resume_transmission_task_with_http_info  rS   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (resume_transmission_tasks_with_http_infor   s       r   resume_transmission_tasksz DTSApi.resume_transmission_tasksg  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method resume_transmission_tasksNzNMissing the required parameter `body` when calling `resume_transmission_tasks`r   r   r   r    z>/ResumeTransmissionTasks/2022-10-01/dts/post/application_json/r!   ResumeTransmissionTasksResponseTr#   r)   r4   s                  r   r   z/DTSApi.resume_transmission_tasks_with_http_info|  rL   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %resume_validation_task_with_http_infor   s       r   resume_validation_taskzDTSApi.resume_validation_task  rW   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method resume_validation_taskNzKMissing the required parameter `body` when calling `resume_validation_task`r   r   r   r    z;/ResumeValidationTask/2022-10-01/dts/post/application_json/r!   ResumeValidationTaskResponseTr#   r)   r4   s                  r   r  z,DTSApi.resume_validation_task_with_http_info  rZ   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   &resume_validation_tasks_with_http_infor   s       r   resume_validation_taskszDTSApi.resume_validation_tasks)  r}   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a"  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.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method resume_validation_tasksNzLMissing the required parameter `body` when calling `resume_validation_tasks`r   r   r   r    z</ResumeValidationTasks/2022-10-01/dts/post/application_json/r!   ResumeValidationTasksResponseTr#   r)   r4   s                  r   r
  z-DTSApi.resume_validation_tasks_with_http_info>  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   &retry_transmission_task_with_http_infor   s       r   retry_transmission_taskzDTSApi.retry_transmission_task  r}   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a"  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.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method retry_transmission_taskNzLMissing the required parameter `body` when calling `retry_transmission_task`r   r   r   r    z</RetryTransmissionTask/2022-10-01/dts/post/application_json/r!   RetryTransmissionTaskResponseTr#   r)   r4   s                  r   r  z-DTSApi.retry_transmission_task_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'retry_transmission_tasks_with_http_infor   s       r   retry_transmission_taskszDTSApi.retry_transmission_tasks  rP   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method retry_transmission_tasksNzMMissing the required parameter `body` when calling `retry_transmission_tasks`r   r   r   r    z=/RetryTransmissionTasks/2022-10-01/dts/post/application_json/r!   RetryTransmissionTasksResponseTr#   r)   r4   s                  r   r  z.DTSApi.retry_transmission_tasks_with_http_info   rS   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $retry_validation_task_with_http_infor   s       r   retry_validation_taskzDTSApi.retry_validation_taskL  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method retry_validation_taskNzJMissing the required parameter `body` when calling `retry_validation_task`r   r   r   r    z:/RetryValidationTask/2022-10-01/dts/post/application_json/r!   RetryValidationTaskResponseTr#   r)   r4   s                  r   r  z+DTSApi.retry_validation_task_with_http_infoa  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %retry_validation_tasks_with_http_infor   s       r   retry_validation_taskszDTSApi.retry_validation_tasks  rW   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method retry_validation_tasksNzKMissing the required parameter `body` when calling `retry_validation_tasks`r   r   r   r    z;/RetryValidationTasks/2022-10-01/dts/post/application_json/r!   RetryValidationTasksResponseTr#   r)   r4   s                  r   r  z,DTSApi.retry_validation_tasks_with_http_info  rZ   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   "spawn_swimming_lane_with_http_infor   s       r   spawn_swimming_lanezDTSApi.spawn_swimming_lane  s]     ,0'(::k"" 	:4:4JJ6JJJ<T<TLLVLLTKr   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zEGot an unexpected keyword argument '%s' to method spawn_swimming_laneNzHMissing the required parameter `body` when calling `spawn_swimming_lane`r   r   r   r    z8/SpawnSwimmingLane/2022-10-01/dts/post/application_json/r!   SpawnSwimmingLaneResponseTr#   r)   r4   s                  r   r#  z)DTSApi.spawn_swimming_lane_with_http_info#  s    X
+&&&2333,---,---fX&677 	 	HC*$$57:;   F3KK8?1 	ivV7K7K7=f~7MghhhV .K"&/"F"F #" #"h )-(R(R )" )"n% **''F#!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1 ( 3 3 	3r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   &start_transmission_task_with_http_infor   s       r   start_transmission_taskzDTSApi.start_transmission_tasko  r}   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a"  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.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method start_transmission_taskNzLMissing the required parameter `body` when calling `start_transmission_task`r   r   r   r    z</StartTransmissionTask/2022-10-01/dts/post/application_json/r!   StartTransmissionTaskResponseTr#   r)   r4   s                  r   r(  z-DTSApi.start_transmission_task_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'start_transmission_tasks_with_http_infor   s       r   start_transmission_taskszDTSApi.start_transmission_tasks  rP   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method start_transmission_tasksNzMMissing the required parameter `body` when calling `start_transmission_tasks`r   r   r   r    z=/StartTransmissionTasks/2022-10-01/dts/post/application_json/r!   StartTransmissionTasksResponseTr#   r)   r4   s                  r   r-  z.DTSApi.start_transmission_tasks_with_http_info  rS   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $start_validation_task_with_http_infor   s       r   start_validation_taskzDTSApi.start_validation_task1  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method start_validation_taskNzJMissing the required parameter `body` when calling `start_validation_task`r   r   r   r    z:/StartValidationTask/2022-10-01/dts/post/application_json/r!   StartValidationTaskResponseTr#   r)   r4   s                  r   r2  z+DTSApi.start_validation_task_with_http_infoF  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %start_validation_tasks_with_http_infor   s       r   start_validation_taskszDTSApi.start_validation_tasks  rW   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method start_validation_tasksNzKMissing the required parameter `body` when calling `start_validation_tasks`r   r   r   r    z;/StartValidationTasks/2022-10-01/dts/post/application_json/r!   StartValidationTasksResponseTr#   r)   r4   s                  r   r7  z,DTSApi.start_validation_tasks_with_http_info  rZ   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   %stop_transmission_task_with_http_infor   s       r   stop_transmission_taskzDTSApi.stop_transmission_task  rW   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zHGot an unexpected keyword argument '%s' to method stop_transmission_taskNzKMissing the required parameter `body` when calling `stop_transmission_task`r   r   r   r    z;/StopTransmissionTask/2022-10-01/dts/post/application_json/r!   StopTransmissionTaskResponseTr#   r)   r4   s                  r   r<  z,DTSApi.stop_transmission_task_with_http_info  rZ   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   &stop_transmission_tasks_with_http_infor   s       r   stop_transmission_taskszDTSApi.stop_transmission_tasksT  r}   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a"  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.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method stop_transmission_tasksNzLMissing the required parameter `body` when calling `stop_transmission_tasks`r   r   r   r    z</StopTransmissionTasks/2022-10-01/dts/post/application_json/r!   StopTransmissionTasksResponseTr#   r)   r4   s                  r   rA  z-DTSApi.stop_transmission_tasks_with_http_infoi  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   #stop_validation_task_with_http_infor   s       r   stop_validation_taskzDTSApi.stop_validation_task  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zFGot an unexpected keyword argument '%s' to method stop_validation_taskNzIMissing the required parameter `body` when calling `stop_validation_task`r   r   r   r    z9/StopValidationTask/2022-10-01/dts/post/application_json/r!   StopValidationTaskResponseTr#   r)   r4   s                  r   rF  z*DTSApi.stop_validation_task_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   $stop_validation_tasks_with_http_infor   s       r   stop_validation_taskszDTSApi.stop_validation_tasks  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a  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.
        r   r   r   r   r   r   zGGot an unexpected keyword argument '%s' to method stop_validation_tasksNzJMissing the required parameter `body` when calling `stop_validation_tasks`r   r   r   r    z:/StopValidationTasks/2022-10-01/dts/post/application_json/r!   StopValidationTasksResponseTr#   r)   r4   s                  r   rK  z+DTSApi.stop_validation_tasks_with_http_info+  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (suspend_transmission_task_with_http_infor   s       r   suspend_transmission_taskz DTSApi.suspend_transmission_taskw  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method suspend_transmission_taskNzNMissing the required parameter `body` when calling `suspend_transmission_task`r   r   r   r    z>/SuspendTransmissionTask/2022-10-01/dts/post/application_json/r!   SuspendTransmissionTaskResponseTr#   r)   r4   s                  r   rP  z/DTSApi.suspend_transmission_task_with_http_info  rL   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   )suspend_transmission_tasks_with_http_infor   s       r   suspend_transmission_tasksz!DTSApi.suspend_transmission_tasks  r   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a.  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.
        r   r   r   r   r   r   zLGot an unexpected keyword argument '%s' to method suspend_transmission_tasksNzOMissing the required parameter `body` when calling `suspend_transmission_tasks`r   r   r   r    z?/SuspendTransmissionTasks/2022-10-01/dts/post/application_json/r!    SuspendTransmissionTasksResponseTr#   r)   r4   s                  r   rU  z0DTSApi.suspend_transmission_tasks_with_http_info  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   &suspend_validation_task_with_http_infor   s       r   suspend_validation_taskzDTSApi.suspend_validation_task9  r}   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a"  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.
        r   r   r   r   r   r   zIGot an unexpected keyword argument '%s' to method suspend_validation_taskNzLMissing the required parameter `body` when calling `suspend_validation_task`r   r   r   r    z</SuspendValidationTask/2022-10-01/dts/post/application_json/r!   SuspendValidationTaskResponseTr#   r)   r4   s                  r   rZ  z-DTSApi.suspend_validation_task_with_http_infoN  r   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   'suspend_validation_tasks_with_http_infor   s       r   suspend_validation_taskszDTSApi.suspend_validation_tasks  rP   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a&  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.
        r   r   r   r   r   r   zJGot an unexpected keyword argument '%s' to method suspend_validation_tasksNzMMissing the required parameter `body` when calling `suspend_validation_tasks`r   r   r   r    z=/SuspendValidationTasks/2022-10-01/dts/post/application_json/r!   SuspendValidationTasksResponseTr#   r)   r4   s                  r   r_  z.DTSApi.suspend_validation_tasks_with_http_info  rS   r   c                 r    d|d<   |                     d          r | j        |fi |S  | j        |fi |}|S )a  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.
        Tr   r   )r   (update_subscription_group_with_http_infor   s       r   update_subscription_groupz DTSApi.update_subscription_group  rI   r   c                 4   dg}|                     d           |                     d           |                     d           |                     d           t                      }t          j        |d                   D ] \  }}||vrt	          d|z            |||<   !|d= | j        j        rd|vs|d         t          d	          i }i }g }	i }
g }i }d}d|v r|d         }| j                            d
g          |
d<   | j        	                    d
g          |
d<   dg}| j        
                    dd||	|
|||d||                    d          |                    d          |                    dd          |                    d          |          S )a*  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.
        r   r   r   r   r   r   zKGot an unexpected keyword argument '%s' to method update_subscription_groupNzNMissing the required parameter `body` when calling `update_subscription_group`r   r   r   r    z>/UpdateSubscriptionGroup/2022-10-01/dts/post/application_json/r!   UpdateSubscriptionGroupResponseTr#   r)   r4   s                  r   rd  z/DTSApi.update_subscription_group_with_http_info  rL   r   r   )u__name__
__module____qualname____doc__r   r   r   rA   r@   rH   rG   rO   rN   rV   rU   r]   r\   rc   rb   rh   rg   rm   rl   rr   rq   rw   rv   r|   r{   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r   r  r  r  r
  r  r  r  r  r  r  r  r  r$  r#  r)  r(  r.  r-  r3  r2  r8  r7  r=  r<  rB  rA  rG  rF  rL  rK  rQ  rP  rV  rU  r[  rZ  r`  r_  re  rd   r   r   r   r      s        % % % %
  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3X  *J3 J3 J3 J3 J3r   r   )rk  
__future__r   rer,   r   objectr   rl  r   r   <module>rp     s     ' & & & & & 				 


    BU3 BU3 BU3 BU3 BU3V BU3 BU3 BU3 BU3 BU3r   