
    Mi                         S r SSKJr  SSKJrJrJrJrJrJ	r	  SSK
Jr  SSKJr  SSKJrJrJr  SSKJrJrJr  SS	KJr   " S
 S\5      rg)zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.   )BaseSDK    )AnyListMappingOptionalUnioncast)utils)HookContext)errors
operationsshared)	BaseModelOptionalNullableUNSET)unmarshal_json_responsec                   |	   \ rS rSr\SSSS.S\\R                  \R                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R                   4S
 jjr\SSSS.S\\R                  \R                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R                   4S jjr\SSSS.S\\R&                  \R(                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R*                  4S jjr\SSSS.S\\R&                  \R(                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R*                  4S jjr\SSSS.S\\R0                  \R2                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R4                  4S jjr\SSSS.S\\R0                  \R2                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R4                  4S jjr\SSSS.S\\R:                  \R<                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R>                  4S jjr \SSSS.S\\R:                  \R<                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R>                  4S jjr!\SSSS.S\\RD                  \RF                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\RH                  4S jjr%\SSSS.S\\RD                  \RF                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\RH                  4S jjr&\SSSS.S\\RN                  \RP                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\RR                  4S jjr*\SSSS.S\\RN                  \RP                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\RR                  4S jjr+\SSSS.S\\RX                  \RZ                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R\                  4S jjr/\SSSS.S\\RX                  \RZ                  4   S\	\
R                     S\\   S\\   S\\\\4      S	\R\                  4S jjr0Sr1g)Sources   N)retries
server_url
timeout_mshttp_headersrequestr   r   r   r   returnc                   SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[6        R>                  " SU
5      ea  Create source connection check

Initiates a connection check for the specified source connector.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
NPOST,/api/v1/sources/{source_id}/connection-checkFT
user-agentapplication/jsonmethodpathbase_urlurl_variablesr   request_body_requiredrequest_has_path_paramsrequest_has_query_paramsuser_agent_headeraccept_header_valuer   securityr   backoff  
 Gz?@w 5xx create_connection_check_sourcesconfigr&   operation_idoauth2_scopessecurity_source4224XX5XXhook_ctxr   error_status_codesretry_config202Content-Typedag_node_connection_checkstatus_codecontent_typeraw_responser<   r=   *API error occurredr>   Unexpected response received) sdk_configurationr   _get_url
isinstancer   r   	unmarshalr   #CreateConnectionCheckSourcesRequestr
   _build_requestr-   r   rB   RetryConfigBackoffStrategy
do_requestr   match_response$CreateConnectionCheckSourcesResponser   r   r   DagNodeConnectionCheckrG   headersgetr   HTTPValidationErrorDataHTTPValidationErrorstream_to_textSDKErrorselfr   r   r   r   r   r&   r'   reqrB   http_resresponse_datahttp_res_texts                u/var/www/eduai.edurigo.com/storigo/production/storigo_env/lib/python3.13/site-packages/unstructured_client/sources.pyr5   'Sources.create_connection_check_sources   s   , //::J!!H}}X=H'9--ooGGG zEEwO!!?'"'$(%)* 2%++44! " 
  e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R>  $ 6 6 ? ? 4% # 
 "%1CDDBB*AV::;X+ %00%--11.AGR%  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGG    c                Z  #    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[6        R>                  " SU
5      e GN N N77fr   ) rM   r   rN   rO   r   r   rP   r   rQ   r
   _build_request_asyncr-   r   rB   rS   rT   do_request_asyncr   rV   rW   r   r   r   rX   rG   rY   rZ   r   r[   r\   stream_to_text_asyncr^   r_   s                re   %create_connection_check_sources_async-Sources.create_connection_check_sources_asynct   s    , //::J!!H}}X=H'9--ooGGG zEEwO''?'"'$(%)* 2%++44! ( 
  e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R>  $ 6 6 ? ? 4% / 
 
 "%1CDDBB*AV::;X+ %00%--11.AGR%  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGG
: G G8   FL+L$DL+L' AL+1L)23L+'L+)L+c                   ^ SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        T[        5      (       d%  [
        R                  " T[        R                  5      m[        [        R                  T5      mU R                  SSUUTSSSSSUU R                   R                  U4S jUS	9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S
[
        R                  " SSSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[6        R>                  " SU
5      e)  Create source connector

Create a new source connector using the provided configuration and name.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
Nr   /api/v1/sources/TFr!   r"   c                  h   > [         R                  " T R                  SSS[        R                  5      $ NFjsonr   serialize_request_bodycreate_source_connectorr   CreateSourceConnectorr   s   re   <lambda>'Sources.create_source.<locals>.<lambda>  +    (D(D//,,)rg   r$   r%   r&   r'   r   r(   r)   r*   r+   r,   r   r-   get_serialized_bodyr   r.   r/   r0   r1   r2   r3   r4   create_sourcer6   r;   r?   200rD   source_connector_informationrG   rH   rI   r<   r=   rJ   rK   r>   rL   ) rM   r   rN   rO   r   r   rP   r   CreateSourceRequestr
   rR   r-   r   rB   rS   rT   rU   r   rV   CreateSourceResponser   r   r   SourceConnectorInformationrG   rY   rZ   r   r[   r\   r]   r^   r_   s    `           re   r   Sources.create_source   s   * //::J!!H}}X=H'9--oogz/M/MNGz55w?!!#'"&$)%)* 2%++44! ") " 
. e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R,  $ 6 6 ? ? 4% # 
 "%1CDD22-DV>>?. %00%--11.AGR%  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGGrg   c                f  ^#    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        T[        5      (       d%  [
        R                  " T[        R                  5      m[        [        R                  T5      mU R                  SSUUTSSSSSUU R                   R                  U4S jUS	9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S
[
        R                  " SSSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[6        R>                  " SU
5      e GN N N77f)rp   Nr   rq   TFr!   r"   c                  h   > [         R                  " T R                  SSS[        R                  5      $ rs   ru   ry   s   re   rz   -Sources.create_source_async.<locals>.<lambda>v  r|   rg   r}   r.   r/   r0   r1   r2   r3   r4   r   r6   r;   r?   r   rD   r   r<   r=   rJ   rK   r>   rL   ) rM   r   rN   rO   r   r   rP   r   r   r
   ri   r-   r   rB   rS   rT   rj   r   rV   r   r   r   r   r   rG   rY   rZ   r   r[   r\   rk   r^   r_   s    `           re   create_source_asyncSources.create_source_asyncF  s    * //::J!!H}}X=H'9--oogz/M/MNGz55w?''#'"&$)%)* 2%++44! ") ( 
. e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R,  $ 6 6 ? ? 4% / 
 
 "%1CDD22-DV>>?. %00%--11.AGR%  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGG
: G G8   FL1L*DL1%L-&AL17L/83L1-L1/L1c                    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       aX  [        R&                  " [)        [*        [,           U
5      U
R.                  U
R0                  R3                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [4        R6                  U
5      n[4        R8                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R:                  " U
5      n[4        R<                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R:                  " U
5      n[4        R<                  " SX5      e[4        R<                  " SU
5      ea  Delete source connector

Delete a specific source connector identified by its ID.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
NDELETE/api/v1/sources/{source_id}FTr!   r"   r#   r.   r/   r0   r1   r2   r3   r4   delete_sourcer6   r;   r?   r   rD   )anyrG   rH   rI   r<   r=   rJ   rK   r>   rL   )rM   r   rN   rO   r   r   rP   r   DeleteSourceRequestr
   rR   r-   r   rB   rS   rT   rU   r   rV   DeleteSourceResponser   r   r   rG   rY   rZ   r   r[   r\   r]   r^   r_   s                re   r   Sources.delete_source  s   * //::J!!H}}X=H'9--oogz/M/MNGz55w?!!.'"'$(%)* 2%++44! " 
  e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R,  $ 6 6 ? ? 4% # 
 "%1CDD22+HSM8D$00%--11.AGR%	  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGGrg   c                F  #    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       aX  [        R&                  " [)        [*        [,           U
5      U
R.                  U
R0                  R3                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [4        R6                  U
5      n[4        R8                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R:                  " U
5      I Sh  vN n[4        R<                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R:                  " U
5      I Sh  vN n[4        R<                  " SX5      e[4        R<                  " SU
5      e GN N N77fr   )rM   r   rN   rO   r   r   rP   r   r   r
   ri   r-   r   rB   rS   rT   rj   r   rV   r   r   r   r   rG   rY   rZ   r   r[   r\   rk   r^   r_   s                re   delete_source_asyncSources.delete_source_async  s    * //::J!!H}}X=H'9--oogz/M/MNGz55w?''.'"'$(%)* 2%++44! ( 
  e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R,  $ 6 6 ? ? 4% / 
 
 "%1CDD22+HSM8D$00%--11.AGR%	  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGC
6 G Gs8   FL!LC>L!LAL!'L(3L!L!L!c                   SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[6        R>                  " SU
5      ea  Get the latest source connector connection check

Retrieves the most recent connection check for the specified source connector.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
NGETr    FTr!   r"   r#   r.   r/   r0   r1   r2   r3   r4   get_connection_check_sourcesr6   r;   r?   r   rD   rE   r<   r=   rJ   rK   r>   rL   ) rM   r   rN   rO   r   r   rP   r    GetConnectionCheckSourcesRequestr
   rR   r-   r   rB   rS   rT   rU   r   rV   !GetConnectionCheckSourcesResponser   r   r   rX   rG   rY   rZ   r   r[   r\   r]   r^   r_   s                re   r   $Sources.get_connection_check_sourcesu  s   , //::J!!H}}X=H'9--ooDDG zBBGL!!?'"'$(%)* 2%++44! " 
  e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R;  $ 6 6 ? ? 4% # 
 "%1CDD??*AV::;X+ %00%--11.AGR%  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGGrg   c                Z  #    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[6        R>                  " SU
5      e GN N N77fr   ) rM   r   rN   rO   r   r   rP   r   r   r
   ri   r-   r   rB   rS   rT   rj   r   rV   r   r   r   r   rX   rG   rY   rZ   r   r[   r\   rk   r^   r_   s                re   "get_connection_check_sources_async*Sources.get_connection_check_sources_async  s    , //::J!!H}}X=H'9--ooDDG zBBGL''?'"'$(%)* 2%++44! ( 
  e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R;  $ 6 6 ? ? 4% / 
 
 "%1CDD??*AV::;X+ %00%--11.AGR%  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGG
: G Grn   c                   SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[6        R>                  " SU
5      ea  Get source connector

Retrieve detailed information for a specific source connector by its ID.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
Nr   r   FTr!   r"   r#   r.   r/   r0   r1   r2   r3   r4   
get_sourcer6   r;   r?   r   rD   r   r<   r=   rJ   rK   r>   rL   ) rM   r   rN   rO   r   r   rP   r   GetSourceRequestr
   rR   r-   r   rB   rS   rT   rU   r   rV   GetSourceResponser   r   r   r   rG   rY   rZ   r   r[   r\   r]   r^   r_   s                re   r   Sources.get_sourceC  s   * //::J!!H}}X=H'9--oogz/J/JKGz22G<!!.'"'$(%)* 2%++44! " 
  e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R)  $ 6 6 ? ? 4% # 
 "%1CDD//-DV>>?. %00%--11.AGR%  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGGrg   c                Z  #    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[6        R>                  " SU
5      e GN N N77fr   ) rM   r   rN   rO   r   r   rP   r   r   r
   ri   r-   r   rB   rS   rT   rj   r   rV   r   r   r   r   r   rG   rY   rZ   r   r[   r\   rk   r^   r_   s                re   get_source_asyncSources.get_source_async  s    * //::J!!H}}X=H'9--oogz/J/JKGz22G<''.'"'$(%)* 2%++44! ( 
  e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R)  $ 6 6 ? ? 4% / 
 
 "%1CDD//-DV>>?. %00%--11.AGR%  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGG
: G Grn   c                "   SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       ai  [        R&                  " [)        [*        [,        [.        R0                        U
5      U
R2                  U
R4                  R7                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [8        R:                  U
5      n[8        R<                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R>                  " U
5      n[8        R@                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R>                  " U
5      n[8        R@                  " SX5      e[8        R@                  " SU
5      ea  List available source connectors

Retrieve a list of available source connectors.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
Nr   rq   FTr!   r"   r#   r.   r/   r0   r1   r2   r3   r4   list_sourcesr6   r;   r?   r   rD   )response_list_sourcesrG   rH   rI   r<   r=   rJ   rK   r>   rL   )!rM   r   rN   rO   r   r   rP   r   ListSourcesRequestr
   rR   r-   r   rB   rS   rT   rU   r   rV   ListSourcesResponser   r   r   r   r   rG   rY   rZ   r   r[   r\   r]   r^   r_   s                re   r   Sources.list_sources  s   * //::J!!H}}X=H'9--oogz/L/LMGz44g>!!#'"'$)%)* 2%++44! " 
  e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R+  $ 6 6 ? ? 4% # 
 "%1CDD11&=T&"C"CDEx' %00%--11.AGR%  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGGrg   c                h  #    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        U[        5      (       d%  [
        R                  " U[        R                  5      n[        [        R                  U5      nU R                  SSUUUSSSSSUU R                   R                  US9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       ai  [        R&                  " [)        [*        [,        [.        R0                        U
5      U
R2                  U
R4                  R7                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [8        R:                  U
5      n[8        R<                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R>                  " U
5      I Sh  vN n[8        R@                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R>                  " U
5      I Sh  vN n[8        R@                  " SX5      e[8        R@                  " SU
5      e GN N N77fr   )!rM   r   rN   rO   r   r   rP   r   r   r
   ri   r-   r   rB   rS   rT   rj   r   rV   r   r   r   r   r   r   rG   rY   rZ   r   r[   r\   rk   r^   r_   s                re   list_sources_asyncSources.list_sources_asynco  s    * //::J!!H}}X=H'9--oogz/L/LMGz44g>''#'"'$)%)* 2%++44! ( 
  e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R+  $ 6 6 ? ? 4% / 
 
 "%1CDD11&=T&"C"CDEx' %00%--11.AGR%  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGG
: G Gs8   FL2L+DL2&L.'AL28L093L2.L20L2c                   ^ SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        T[        5      (       d%  [
        R                  " T[        R                  5      m[        [        R                  T5      mU R                  SSUUTSSSSSUU R                   R                  U4S jUS9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a-  [
        R<                  " U
5      n[6        R>                  " SX5      e[6        R>                  " SU
5      e)  Update source connector

Update the configuration of an existing source connector.

:param request: The request object to send.
:param retries: Override the default retry configuration for this method
:param server_url: Override the default server URL for this method
:param timeout_ms: Override the default request timeout configuration for this method in milliseconds
:param http_headers: Additional headers to set or replace on requests.
NPUTr   Tr!   r"   c                  h   > [         R                  " T R                  SSS[        R                  5      $ rs   r   rv   update_source_connectorr   UpdateSourceConnectorry   s   re   rz   'Sources.update_source.<locals>.<lambda>  r|   rg   r}   r.   r/   r0   r1   r2   r3   r4   update_sourcer6   r;   r?   r   rD   r   r<   r=   rJ   rK   r>   rL   ) rM   r   rN   rO   r   r   rP   r   UpdateSourceRequestr
   rR   r-   r   rB   rS   rT   rU   r   rV   UpdateSourceResponser   r   r   r   rG   rY   rZ   r   r[   r\   r]   r^   r_   s    `           re   r   Sources.update_source  s   * //::J!!H}}X=H'9--oogz/M/MNGz55w?!!.'"&$(%)* 2%++44! ") " 
. e%%22%?00==++u44T64QSW gu0011#eW-L?? --!R,  $ 6 6 ? ? 4% # 
 "%1CDD22-DV>>?. %00%--11.AGR%  %1CDD3..M ,,]EE%55!00:M//"6PP%55!00:M//"6PPoo<hGGrg   c                f  ^#    SnSnUc  U R                   R                  nUb  UnOU R                  Xg5      n[        T[        5      (       d%  [
        R                  " T[        R                  5      m[        [        R                  T5      mU R                  SSUUTSSSSSUU R                   R                  U4S jUS9nU[        :X  ac  U R                   R                  [        La  U R                   R                  nO/[
        R                  " S	[
        R                  " S
SSS5      S5      nSn	[        U[
        R                  5      (       a  US/4n	U R!                  [#        U R                   U=(       d    SS/ U R                   R                  S9U/ SQU	S9I Sh  vN n
Sn[
        R$                  " U
SS5      (       ab  [        R&                  " [)        [*        [,        R.                     U
5      U
R0                  U
R2                  R5                  S5      =(       d    SU
S9$ [
        R$                  " U
SS5      (       a0  [)        [6        R8                  U
5      n[6        R:                  " X5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[
        R$                  " U
SS5      (       a5  [
        R<                  " U
5      I Sh  vN n[6        R>                  " SX5      e[6        R>                  " SU
5      e GN N N77f)r   Nr   r   Tr!   r"   c                  h   > [         R                  " T R                  SSS[        R                  5      $ rs   r   ry   s   re   rz   -Sources.update_source_async.<locals>.<lambda>n  r|   rg   r}   r.   r/   r0   r1   r2   r3   r4   r   r6   r;   r?   r   rD   r   r<   r=   rJ   rK   r>   rL   ) rM   r   rN   rO   r   r   rP   r   r   r
   ri   r-   r   rB   rS   rT   rj   r   rV   r   r   r   r   r   rG   rY   rZ   r   r[   r\   rk   r^   r_   s    `           re   update_source_asyncSources.update_source_async>  s    * //::J!!H}}X=H'9--oogz/M/MNGz55w?''.'"&$(%)* 2%++44! ") ( 
. e%%22%?00==++u44T64QSW gu0011#eW-L.. --!R,  $ 6 6 ? ? 4% / 
 
 "%1CDD22-DV>>?. %00%--11.AGR%  %1CDD3..M ,,]EE%55"'"<"<X"FFM//"6PP%55"'"<"<X"FFM//"6PPoo<hGGG
: G Gr    )2__name__
__module____qualname____firstlineno__r   r	   r   rQ   ,CreateConnectionCheckSourcesRequestTypedDictr   r   rS   r   strintr   rW   r5   rl   r   CreateSourceRequestTypedDictr   r   r   r   DeleteSourceRequestTypedDictr   r   r   r   )GetConnectionCheckSourcesRequestTypedDictr   r   r   r   GetSourceRequestTypedDictr   r   r   r   ListSourcesRequestTypedDictr   r   r   r   UpdateSourceRequestTypedDictr   r   r   __static_attributes__r   rg   re   r   r      s    8=$($(48eH ::CCE
eH "%"3"34eH SMeH SMeH wsCx01eH 
	8	8eH\ 8=$($(48eH ::CCE
eH "%"3"34eH SMeH SMeH wsCx01eH 
	8	8eHZ 8=$($(48iH **J,S,SS
iH "%"3"34iH SMiH SMiH wsCx01iH 
	(	(iHb 8=$($(48iH **J,S,SS
iH "%"3"34iH SMiH SMiH wsCx01iH 
	(	(iHb 8=$($(48`H **J,S,SS
`H "%"3"34`H SM`H SM`H wsCx01`H 
	(	(`HP 8=$($(48`H **J,S,SS
`H "%"3"34`H SM`H SM`H wsCx01`H 
	(	(`HR 8=$($(48eH 77@@B
eH "%"3"34eH SMeH SMeH wsCx01eH 
	5	5eH\ 8=$($(48eH 77@@B
eH "%"3"34eH SMeH SMeH wsCx01eH 
	5	5eHZ 8=$($(48bH '')M)MM
bH "%"3"34bH SMbH SMbH wsCx01bH 
	%	%bHT 8=$($(48bH '')M)MM
bH "%"3"34bH SMbH SMbH wsCx01bH 
	%	%bHT 8=$($(48bH )):+Q+QQ
bH "%"3"34bH SMbH SMbH wsCx01bH 
	'	'bHT 8=$($(48bH )):+Q+QQ
bH "%"3"34bH SMbH SMbH wsCx01bH 
	'	'bHT 8=$($(48iH **J,S,SS
iH "%"3"34iH SMiH SMiH wsCx01iH 
	(	(iHb 8=$($(48iH **J,S,SS
iH "%"3"34iH SMiH SMiH wsCx01iH 
	(	(iH iHrg   r   N)__doc__basesdkr   typingr   r   r   r   r	   r
   unstructured_clientr   unstructured_client._hooksr   unstructured_client.modelsr   r   r   unstructured_client.typesr   r   r   1unstructured_client.utils.unmarshal_json_responser   r   r   rg   re   <module>r      s6    G  < < % 2 A A H H U[Hg [Hrg   