
    Ng                         d Z ddlZddlZddlZddlmZ ddlZ G d d          Z G d d          Z G d d	          Z	 G d
 de
          Z G d de
          Zde	fdZde	fdZ	 	 	 	 ddZ	 	 	 	 ddZdS )zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.    N)Listc                   P    e Zd ZU eed<   eed<   eed<   eed<   dedededefdZdS )BackoffStrategyinitial_intervalmax_intervalexponentmax_elapsed_timec                 >    || _         || _        || _        || _        d S N)r   r   r   r	   )selfr   r   r   r	   s        ]/var/www/html/ai-engine/env/lib/python3.11/site-packages/unstructured_client/utils/retries.py__init__zBackoffStrategy.__init__   s)     !1(  0    N)__name__
__module____qualname__int__annotations__floatr    r   r   r   r      s}         OOO
1
1 
1 	
1
 
1 
1 
1 
1 
1 
1r   r   c                   B    e Zd ZU eed<   eed<   eed<   dededefdZdS )RetryConfigstrategybackoffretry_connection_errorsc                 0    || _         || _        || _        d S r   )r   r   r   )r   r   r   r   s       r   r   zRetryConfig.__init__#   s      !'>$$$r   N)r   r   r   strr   r   boolr   r   r   r   r   r      sc         MMM!!!!??&5?PT? ? ? ? ? ?r   r   c                   L    e Zd ZU eed<   ee         ed<   dedee         fdZdS )Retriesconfigstatus_codesc                 "    || _         || _        d S r   )r!   r"   )r   r!   r"   s      r   r   zRetries.__init__/   s    (r   N)r   r   r   r   r   r   r   r   r   r   r   r    r    +   sX         s)){ )$s) ) ) ) ) ) )r   r    c                   :    e Zd ZU ej        ed<   dej        fdZdS )TemporaryErrorresponsec                     || _         d S r   )r&   )r   r&   s     r   r   zTemporaryError.__init__7   s     r   N)r   r   r   httpxResponser   r   r   r   r   r%   r%   4   sA         n! ! ! ! ! ! !r   r%   c                   &    e Zd ZU eed<   defdZdS )PermanentErrorinnerc                     || _         d S r   )r,   )r   r,   s     r   r   zPermanentError.__init__>   s    


r   N)r   r   r   	Exceptionr   r   r   r   r   r+   r+   ;   s=         i      r   r+   retriesc                      j         j        dk    rbdt          j        f fd}t	          |j         j        j        j         j        j        j         j        j        j         j        j	                  S               S )Nr   returnc                  J   	              } j         D ]}d|                                v rBt          |d                   }| j        dz  }||cxk    r	|dz   k     rn Jt	          |           Zt          |          }| j        |k    rt	          |           n# t
          j        $ r"}j        j        r t          |          |d }~wt
          j
        $ r"}j        j        r t          |          |d }~wt          $ r  t          $ r}t          |          |d }~ww xY w| S NXr   d      r"   upperr   status_coder%   r(   ConnectErrorr!   r   r+   TimeoutExceptionr.   rescode
code_rangestatus_majorparsed_code	exceptionfuncr/   s         r   
do_requestzretry.<locals>.do_requestE   s~   ?dff#0 6 6Ddjjll**%(a\\
'*'<%FFFF
QFFFFF"0"5"55 G '*$ii?k99"0"5"55 :6 % ? ? ?>9 $Y//Y>) ? ? ?>9 $Y//Y>!    ? ? ?$Y//Y>? Js0   BB D (CD C44D DD )
r!   r   r(   r)   retry_with_backoffr   r   r   r   r	   rC   r/   rD   s   `` r   retryrG   B   s    ~)++!	EN !	 !	 !	 !	 !	 !	 !	F "N"3N"/N"+N"3
 
 	
 466Mr   c                    K   j         j        dk    rhdt          j        f fd}t	          |j         j        j        j         j        j        j         j        j        j         j        j	                   d {V S                d {V S )Nr   r1   c                  Z  K   	               d {V } j         D ]}d|                                v rBt          |d                   }| j        dz  }||cxk    r	|dz   k     rn Jt	          |           Zt          |          }| j        |k    rt	          |           n# t
          j        $ r"}j        j        r t          |          |d }~wt
          j
        $ r"}j        j        r t          |          |d }~wt          $ r  t          $ r}t          |          |d }~ww xY w| S r3   r7   r<   s         r   rD   zretry_async.<locals>.do_requestv   s     ? DFFllllll#0 6 6Ddjjll**%(a\\
'*'<%FFFF
QFFFFF"0"5"55 G '*$ii?k99"0"5"55 :6 % ? ? ?>9 $Y//Y>) ? ? ?>9 $Y//Y>!    ? ? ?$Y//Y>? Js0   BB! !D(0CD(C<<D(D##D()
r!   r   r(   r)   retry_with_backoff_asyncr   r   r   r   r	   rF   s   `` r   retry_asyncrK   s   s      ~)++!	%. !	 !	 !	 !	 !	 !	 !	F .N"3N"/N"+N"3
 
 
 
 
 
 
 
 	
 <<<<<<r     `        ?6 c                    t          t          j                    dz            }d}	 	  |             S # t          $ r}|j        d }~wt          $ r}t          t          j                    dz            }||z
  |k    r"t          |t                    r|j        cY d }~S  |dz  ||z  z  t          j	        dd          z   }	t          |	|dz            }	t          j        |	           |dz  }Y d }~nd }~ww xY wҩNi  r   Tr6   )roundtimer+   r,   r.   
isinstancer%   r&   randomuniformminsleep
rC   r   r   r   r	   startr/   rB   nowrX   s
             r   rE   rE      s+    $)++$%%EG	466M 	" 	" 	"/! 
	 
	 
		d*++CU{---i88 .$-------%,'0AAFNSTVWDXDXXE|d233EJuqLGGGGGG
	s.   	2 
C5AC5AC0C5AC00C5c                   K   t          t          j                    dz            }d}	 	  |              d {V S # t          $ r}|j        d }~wt          $ r}t          t          j                    dz            }||z
  |k    r"t          |t                    r|j        cY d }~S  |dz  ||z  z  t          j	        dd          z   }	t          |	|dz            }	t          j        |	           d {V  |dz  }Y d }~nd }~ww xY wrQ   )rR   rS   r+   r,   r.   rT   r%   r&   rU   rV   rW   asynciorX   rY   s
             r   rJ   rJ      sN      $)++$%%EG	<<<<<< 	" 	" 	"/! 
	 
	 
		d*++CU{---i88 .$-------%,'0AAFNSTVWDXDXXE|d233E-&&&&&&&&&qLGGGGGG
	s/   : 
DADAC>D%AC>>D)rL   rM   rN   rO   )__doc__r]   rU   rS   typingr   r(   r   r   r    r.   r%   r+   rG   rK   rE   rJ   r   r   r   <module>r`      s   G G          1 1 1 1 1 1 1 1&
? 
? 
? 
? 
? 
? 
? 
?) ) ) ) ) ) ) )! ! ! ! !Y ! ! !    Y   . . . . .b.W . . . .f    <      r   