+
    i4                       R t ^ RIHt ^ RIt^ RIt^ RIt^ RIHt ^ RIHt ^ RIH	t	 ^ RIH
t
 ^ RIHt ^ RIHt ^ R	IHt ^ R
IHt ^ RIHt ^ RIHt ^RIHt ^RIHt ^RIHt ^RIHt ^RIHt ^RIHt ]'       d   ^RIHt ^RIHt ^RIHt ^RIHt ^RIH t   ! R R]4      t! ! R R]4      t" ! R R4      t# ! R R4      t$ ! R  R!]$4      t% ! R" R#]4      t& ! R$ R%]&4      t' ! R& R'4      t(R# )(z?generic asyncio-adapted versions of DBAPI connection and cursor)annotationsN)Any)AsyncIterator)Deque)Iterator)NoReturn)Optional)Sequence)Tuple)Type)TYPE_CHECKING)AdaptedConnection)
EMPTY_DICT)await_fallback)
await_only)in_greenlet)Protocol)_DBAPICursorDescription)_DBAPIMultiExecuteParams)_DBAPISingleExecuteParams)DBAPIModule)Selfc                  V    ] tR t^)tRtR R ltR R ltR R ltR R	 ltR
 R lt	Rt
R# )AsyncIODBAPIConnectionzVprotocol representing an async adapted version of a
:pep:`249` database connection.


c                   V ^8  d   QhRR/#    returnNone )formats   "چC:\Users\petid\OneDrive\Desktop\Maestro\MAESTRO CLAUDE\MAESTRO\maestro-backend\venv\Lib\site-packages\sqlalchemy\connectors\asyncio.py__annotate__#AsyncIODBAPIConnection.__annotate__3   s    ''d'    c                	   "   R # 5iNr   selfs   &r!   commitAsyncIODBAPIConnection.commit3   s     C   c               $    V ^8  d   QhRRRRRR/# )r   argsr   kwargsr   AsyncIODBAPICursorr   )r    s   "r!   r"   r#   5   s    JJCJ3J3EJr$   c                	    R # r&   r   )r(   r-   r.   s   &*,r!   cursorAsyncIODBAPIConnection.cursor5   s    sr$   c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r#   7   s    )))r$   c                	   "   R # 5ir&   r   r'   s   &r!   rollbackAsyncIODBAPIConnection.rollback7   s     cr+   c                    V ^8  d   QhRRRR/# r   keystrr   r   r   )r    s   "r!   r"   r#   9   s    //s/s/r$   c                	    R # r&   r   r(   r9   s   &&r!   __getattr__"AsyncIODBAPIConnection.__getattr__9   s    Cr$   c               $    V ^8  d   QhRRRRRR/# )r   r9   r:   valuer   r   r   r   )r    s   "r!   r"   r#   ;   s    <<s<3<4<r$   c                	    R # r&   r   )r(   r9   r@   s   &&&r!   __setattr__"AsyncIODBAPIConnection.__setattr__;   s    r$   r   N)__name__
__module____qualname____firstlineno____doc__r)   r1   r5   r=   rB   __static_attributes__r   r$   r!   r   r   )   s     (J)/<<r$   r   c                      ] tR t^>t$ RtR R lt]R R l4       t]R R l4       tR]	R	&   R]	R
&   R R lt
R#R R lltR R ltR R ltR$R R lltR R ltR R ltR R ltR$R R lltR R ltR  R! ltR"tR# )%r/   zRprotocol representing an async adapted version
of a :pep:`249` database cursor.


c                   V ^8  d   QhRR/# )r   r   r   r   )r    s   "r!   r"   AsyncIODBAPICursor.__annotate__E   s    $$C$r$   c                	    R # r&   r   r'   s   &r!   
__aenter__AsyncIODBAPICursor.__aenter__E   s    r$   c                   V ^8  d   QhRR/# )r   r   r   r   )r    s   "r!   r"   rL   H   s      	 r$   c                    R# )z(The description attribute of the Cursor.Nr   r'   s   &r!   descriptionAsyncIODBAPICursor.descriptionG   s    
 	r$   c                   V ^8  d   QhRR/# r   r   intr   )r    s   "r!   r"   rL   O   s    ""#"r$   c                	    R # r&   r   r'   s   &r!   rowcountAsyncIODBAPICursor.rowcountN   s    "r$   rV   	arraysize	lastrowidc                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   rL   U   s    &&T&r$   c                	   "   R # 5ir&   r   r'   s   &r!   closeAsyncIODBAPICursor.closeU   s     3r+   Nc               $    V ^8  d   QhRRRRRR/# r   	operationr   
parametersz#Optional[_DBAPISingleExecuteParams]r   r   )r    s   "r!   r"   rL   W   s(       8 
	r$   c                	   "   R # 5ir&   r   r(   rb   rc   s   &&&r!   executeAsyncIODBAPICursor.executeW   
      r+   c               $    V ^8  d   QhRRRRRR/# )r   rb   r   rc   r   r   r   )r    s   "r!   r"   rL   ]   s(       - 
	r$   c                	   "   R # 5ir&   r   re   s   &&&r!   executemanyAsyncIODBAPICursor.executemany]   rh   r+   c                   V ^8  d   QhRR/# r   r   zOptional[Any]r   )r    s   "r!   r"   rL   c       222r$   c                	   "   R # 5ir&   r   r'   s   &r!   fetchoneAsyncIODBAPICursor.fetchonec        sr+   c                    V ^8  d   QhRRRR/# r   sizeOptional[int]r   Sequence[Any]r   )r    s   "r!   r"   rL   e   s    NNMNMNr$   c                	   "   R # 5ir&   r   r(   rv   s   &&r!   	fetchmanyAsyncIODBAPICursor.fetchmanye   s     3r+   c                   V ^8  d   QhRR/# r   r   rx   r   )r    s   "r!   r"   rL   g   ro   r$   c                	   "   R # 5ir&   r   r'   s   &r!   fetchallAsyncIODBAPICursor.fetchallg   rs   r+   c                    V ^8  d   QhRRRR/# )r   sizesrx   r   r   r   )r    s   "r!   r"   rL   i   s    DDD4Dr$   c                	   "   R # 5ir&   r   )r(   r   s   &&r!   setinputsizes AsyncIODBAPICursor.setinputsizesi   s     r+   c               $    V ^8  d   QhRRRRRR/# )r   rv   r   columnr   r   r   )r    s   "r!   r"   rL   k   s    @@#@s@t@r$   c                	    R # r&   r   )r(   rv   r   s   &&&r!   setoutputsize AsyncIODBAPICursor.setoutputsizek   s    Sr$   c               $    V ^8  d   QhRRRRRR/# )r   procnamer:   rc   rx   r   r   r   )r    s   "r!   r"   rL   m   s$      )6	r$   c                	   "   R # 5ir&   r   )r(   r   rc   s   &&&r!   callprocAsyncIODBAPICursor.callprocm   s     r+   c                   V ^8  d   QhRR/# )r   r   zOptional[bool]r   )r    s   "r!   r"   rL   q   s    22~2r$   c                	   "   R # 5ir&   r   r'   s   &r!   nextsetAsyncIODBAPICursor.nextsetq   rs   r+   c                   V ^8  d   QhRR/# )r   r   zAsyncIterator[Any]r   )r    s   "r!   r"   rL   s   s    22-2r$   c                	    R # r&   r   r'   s   &r!   	__aiter__AsyncIODBAPICursor.__aiter__s   s    sr$   r   r&   ).)rD   rE   rF   rG   rH   rN   propertyrR   rX   __annotations__r^   rf   rk   rq   r{   r   r   r   r   r   r   rI   r   r$   r!   r/   r/   >   sf     %  " "NN& 3N2D@ 322r$   r/   c                      ] tR t^vt]'       d;   ]P                  t]P                  t]P                  t]P                  t	R R lt
RtR# RtR# )AsyncAdapt_dbapi_modulec                    V ^8  d   QhRRRR/# r8   r   )r    s   "r!   r"   $AsyncAdapt_dbapi_module.__annotate__}   s    333333r$   c                	    R # r&   r   r<   s   &&r!   r=   #AsyncAdapt_dbapi_module.__getattr__}   s    r$   r   N)rD   rE   rF   rG   r   r   ErrorOperationalErrorInterfaceErrorIntegrityErrorr=   rI   r   r$   r!   r   r   v   s=    !!&77$33$3333 r$   r   c                     ] tR t^t$ RtR;tRtR]R&   R	]R&   R
]R&   R]R&   R]R&   R R ltR R lt	R R lt
]R R l4       t]R R l4       t]R R l4       t]P                  R R l4       t]R R l4       tR R ltR R  ltR<R" R# lltR$ R% ltR& R' ltR( R) ltR* R+ ltR, R- ltR. R/ ltR0 R1 ltR2 R3 ltR4 R5 ltR<R6 R7 lltR8 R9 ltR:tR!# )=AsyncAdapt_dbapi_cursorF_adapt_connection_connection_cursor_rowsTbool_awaitable_cursor_closer/   AsyncAdapt_dbapi_connectionr   z
Deque[Any]c                   V ^8  d   QhRR/# )r   adapt_connectionr   r   )r    s   "r!   r"   $AsyncAdapt_dbapi_cursor.__annotate__   s     
- 
-)D 
-r$   c                	*   Wn         VP                  V n        VP                  V n        V P                  V P                  4      pV P	                  V4      V n        \        V n        V P                  '       g   \        P                  ! 4       V n        R # R # r&   )r   r   await__make_new_cursor_aenter_cursorr   r   _soft_closed_memoizedserver_sidecollectionsdequer   )r(   r   r1   s   && r!   __init__ AsyncAdapt_dbapi_cursor.__init__   st    !1+77&--&&t'7'78**62%/"$**,DJ  r$   c                    V ^8  d   QhRRRR/# )r   r1   r/   r   r   )r    s   "r!   r"   r      s     0 0%7 0<N 0r$   c                	@    V P                  VP                  4       4      # r&   )r   rN   )r(   r1   s   &&r!   r   &AsyncAdapt_dbapi_cursor._aenter_cursor   s    {{6,,.//r$   c                    V ^8  d   QhRRRR/# )r   
connectionr   r   r/   r   )r    s   "r!   r"   r      s     # #0#	#r$   c                	"    VP                  4       # r&   )r1   )r(   r   s   &&r!   r   (AsyncAdapt_dbapi_cursor._make_new_cursor   s       ""r$   c                   V ^8  d   QhRR/# )r   r   z!Optional[_DBAPICursorDescription]r   )r    s   "r!   r"   r      s     ( (> (r$   c                	v    R V P                   9   d   V P                   R ,          # V P                  P                  # )rR   )r   r   rR   r'   s   &r!   rR   #AsyncAdapt_dbapi_cursor.description   s1    D666--m<<||'''r$   c                   V ^8  d   QhRR/# rU   r   )r    s   "r!   r"   r      s     % %# %r$   c                	.    V P                   P                  # r&   )r   rX   r'   s   &r!   rX    AsyncAdapt_dbapi_cursor.rowcount   s    ||$$$r$   c                   V ^8  d   QhRR/# rU   r   )r    s   "r!   r"   r           & &3 &r$   c                	.    V P                   P                  # r&   r   rZ   r'   s   &r!   rZ   !AsyncAdapt_dbapi_cursor.arraysize       ||%%%r$   c                    V ^8  d   QhRRRR/# )r   r@   rV   r   r   r   )r    s   "r!   r"   r      s     ' 's 't 'r$   c                	&    WP                   n        R # r&   r   )r(   r@   s   &&r!   rZ   r      s    !&r$   c                   V ^8  d   QhRR/# rU   r   )r    s   "r!   r"   r      r   r$   c                	.    V P                   P                  # r&   )r   r[   r'   s   &r!   r[   !AsyncAdapt_dbapi_cursor.lastrowid   r   r$   c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r      s     # # #r$   c                  "   V P                   '       d   V P                  '       d   R# V P                  P                  RV P                  P
                  /4      V n        V P                  P                  4       G Rj  xL
  R#  L5i)zgclose the cursor but keep the results pending, and memoize the
description.

.. versionadded:: 2.0.44

NrR   )r   r   r   unionr   rR   r^   r'   s   &r!   _async_soft_close)AsyncAdapt_dbapi_cursor._async_soft_close   sf      +++t/?/?/?%)%?%?%E%Et||77&
"
 ll  """s   $BAB<B=Bc                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r      s     . .t .r$   c                	b   V P                   P                  4        V P                  e   \        V P                  4      '       d   R # V P
                  '       g   V P                  P                  4        R # \        4       '       d,   V P                  V P                  P                  4       4       R # R # r&   )	r   clearr   r   r   r   r^   r   r   r'   s   &r!   r^   AsyncAdapt_dbapi_cursor.close   sr    

 <<4(B(B#C#C+++LL ]]KK**,- r$   Nc               $    V ^8  d   QhRRRRRR/# ra   r   )r    s   "r!   r"   r      s(     < << 8< 
	<r$   c                	     V P                  V P                  W4      4      #   \         d'   pT P                  P	                  T4        R p?R # R p?ii ; ir&   )r   _execute_async	Exceptionr   _handle_exception)r(   rb   rc   errors   &&& r!   rf   AsyncAdapt_dbapi_cursor.execute   sH    
	<;;t229IJJ 	<""44U;;	<   " AAAc               $    V ^8  d   QhRRRRRR/# r   rb   r   seq_of_parametersr   r   r   )r    s   "r!   r"   r      s(     
< 
<
< 4
< 
	
<r$   c                	     V P                  V P                  W4      4      #   \         d'   pT P                  P	                  T4        R p?R # R p?ii ; ir&   )r   _executemany_asyncr   r   r   )r(   rb   r   r   s   &&& r!   rk   #AsyncAdapt_dbapi_cursor.executemany   sO    
	<;;''	E   	<""44U;;	<r   c               $    V ^8  d   QhRRRRRR/# ra   r   )r    s   "r!   r"   r      s$      *M	r$   c                	6  "   V P                   P                  ;_uu_4       GR j  xL
  Vf%   V P                  P                  V4      G R j  xL
 pM#V P                  P                  W4      G R j  xL
 pV P                  P                  '       dN   V P
                  '       g<   \        P                  ! V P                  P                  4       G R j  xL
 4      V n	        TuuR R R 4      GR j  xL
  #  L L L L' L  + GR j  xL 
 '       g   i     R # ; i5ir&   )
r   _execute_mutexr   rf   rR   r   r   r   r   r   )r(   rb   rc   results   &&& r!   r   &AsyncAdapt_dbapi_cursor._execute_async   s      ))8888!#||33I>>#||33IJJ||'''0@0@0@(..T\\5J5J5L/LM
 988>J 0M 9888s   #DC2D#C<C4#C<0C61C<C<#-C<C8C<D,C:-D4C<6C<8C<:D<D	D
D	D		Dc               $    V ^8  d   QhRRRRRR/# r   r   )r    s   "r!   r"   r     s-     P PP 4P 
	Pr$   c                	  "   V P                   P                  ;_uu_4       GR j  xL
  V P                  P                  W4      G R j  xL
 uuR R R 4      GR j  xL
  #  L9 L L	  + GR j  xL 
 '       g   i     R # ; i5ir&   )r   r   r   rk   )r(   rb   r   s   &&&r!   r   *AsyncAdapt_dbapi_cursor._executemany_async  sM     
 ))888811)OO 988O 9888s\   #BABA%A!	A%BA#B!A%#B%A?	+A.,
A?	7A?	9	Bc                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r   	  s       r$   c                	@   V P                  V P                  P                  4       4       V P                  P                  '       dY   V P                  '       gE   \
        P                  ! V P                  V P                  P                  4       4      4      V n        R # R # R # r&   )	r   r   r   rR   r   r   r   r   r   r'   s   &r!   r   AsyncAdapt_dbapi_cursor.nextset	  si    DLL((*+<<###D,<,<,<$**DLL1134DJ -=#r$   c                    V ^8  d   QhRRRR/# )r   
inputsizesr   r   r   r   )r    s   "r!   r"   r     s     D D D Dr$   c                	T    V P                  V P                  P                  ! V!  4      # r&   )r   r   r   )r(   r   s   &*r!   r   %AsyncAdapt_dbapi_cursor.setinputsizes  s"    
 {{4<<55zBCCr$   c                   V ^8  d   QhRR/# )r   r   r   r   )r    s   "r!   r"   r     s      4 r$   c                	    V # r&   r   r'   s   &r!   	__enter__!AsyncAdapt_dbapi_cursor.__enter__  s    r$   c               (    V ^8  d   QhRRRRRRRR/# )r   type_r   r@   	tracebackr   r   r   )r    s   "r!   r"   r     s(      c # # $ r$   c                	&    V P                  4        R # r&   )r^   )r(   r   r@   r   s   &&&&r!   __exit__ AsyncAdapt_dbapi_cursor.__exit__  s    

r$   c                   V ^8  d   QhRR/# r   r   zIterator[Any]r   )r    s   "r!   r"   r     s     ' '- 'r$   c              #  	n   "   V P                   '       d   V P                   P                  4       x  K0  R # 5ir&   r   popleftr'   s   &r!   __iter__ AsyncAdapt_dbapi_cursor.__iter__  s&     jjj**$$&& s   5 5c                   V ^8  d   QhRR/# rn   r   )r    s   "r!   r"   r   !  s      - r$   c                	^    V P                   '       d   V P                   P                  4       # R # r&   r  r'   s   &r!   rq    AsyncAdapt_dbapi_cursor.fetchone!  s!    :::::%%''r$   c                    V ^8  d   QhRRRR/# ru   r   )r    s   "r!   r"   r   '  s     A Am A} Ar$   c                	    Vf   V P                   pV P                  p\        \        V\	        V4      4      4       Uu. uF  q2P                  4       NK  	  up# u upi r&   )rZ   r   rangeminlenr  )r(   rv   rr_s   &&  r!   r{   !AsyncAdapt_dbapi_cursor.fetchmany'  sG    <>>DZZ&+Cc"g,>&?@&?

&?@@@s   Ac                   V ^8  d   QhRR/# r~   r   )r    s   "r!   r"   r   -  s      - r$   c                	d    \        V P                  4      pV P                  P                  4        V# r&   )listr   r   )r(   retvals   & r!   r    AsyncAdapt_dbapi_cursor.fetchall-  s%    djj!

r$   )r   r   r   r   r   r   )r   r   r   r   r   r   r&   ) rD   rE   rF   rG   r   	__slots__r   r   r   r   r   r   rR   rX   rZ   setterr[   r   r^   rf   rk   r   r   r   r   r   r  r  rq   r{   r   rI   r   r$   r!   r   r      s    KI %)T(22''
-0#
 ( (
 % % & & ' ' & &#$. <
<PD'A r$   r   c                  ^    ] tR tRtRtRtR R ltR R ltRR R	 lltR
 R lt	R R lt
RtR# )AsyncAdapt_dbapi_ss_cursori3  Tc                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   'AsyncAdapt_dbapi_ss_cursor.__annotate__7  s        t  r$   c                	    V P                   e3   V P                  V P                   P                  4       4       R V n         R # R # r&   )r   r   r^   r'   s   &r!   r^    AsyncAdapt_dbapi_ss_cursor.close7  s1    <<#KK**,-DL $r$   c                   V ^8  d   QhRR/# rn   r   )r    s   "r!   r"   r  <       4 4- 4r$   c                	T    V P                  V P                  P                  4       4      # r&   )r   r   rq   r'   s   &r!   rq   #AsyncAdapt_dbapi_ss_cursor.fetchone<      {{4<<00233r$   Nc                    V ^8  d   QhRRRR/# )r   rv   rw   r   r   r   )r    s   "r!   r"   r  ?  s     > >m >s >r$   c                	X    V P                  V P                  P                  VR 7      4      # ))rv   )r   r   r{   rz   s   &&r!   r{   $AsyncAdapt_dbapi_ss_cursor.fetchmany?  s#    {{4<<11t1<==r$   c                   V ^8  d   QhRR/# r~   r   )r    s   "r!   r"   r  B  r#  r$   c                	T    V P                  V P                  P                  4       4      # r&   )r   r   r   r'   s   &r!   r   #AsyncAdapt_dbapi_ss_cursor.fetchallB  r&  r$   c                   V ^8  d   QhRR/# r  r   )r    s   "r!   r"   r  E  s      - r$   c              #  	   "   V P                   P                  4       p  V P                  VP                  4       4      x  K%    \         d     R# i ; i5i)TN)r   r   r   	__anext__StopAsyncIteration)r(   iterators   & r!   r  #AsyncAdapt_dbapi_ss_cursor.__iter__E  sH     <<))+kk("4"4"677% s(   A!A  AAAAA)r   r   r&   )rD   rE   rF   rG   r  r   r^   rq   r{   r   r  rI   r   r$   r!   r  r  3  s*    IK 
4>4 r$   r  c                      ] tR tRt$ ]t]t]! ]	4      t
RtR]R&   R R ltRR R lltRR	 R
 lltR R ltR R ltR R ltR R ltRtR# )r   iN  r   r   c                    V ^8  d   QhRRRR/# )r   dbapir   r   r   r   )r    s   "r!   r"   (AsyncAdapt_dbapi_connection.__annotate__X  s     - -c -/E -r$   c                	R    Wn         W n        \        P                  ! 4       V n        R # r&   )r5  r   asyncioLockr   )r(   r5  r   s   &&&r!   r   $AsyncAdapt_dbapi_connection.__init__X  s    
%%llnr$   c                    V ^8  d   QhRRRR/# )r   r   r   r   r   r   )r    s   "r!   r"   r6  ]  s     * *$ *3J *r$   c                	V    V'       d   V P                  V 4      # V P                  V 4      # r&   )_ss_cursor_cls_cursor_cls)r(   r   s   &&r!   r1   "AsyncAdapt_dbapi_connection.cursor]  s'    &&t,,##D))r$   Nc               $    V ^8  d   QhRRRRRR/# ra   r   )r    s   "r!   r"   r6  c  s(       8 
	r$   c                H    V P                  4       pVP                  W4       V# )z2lots of DBAPIs seem to provide this, so include it)r1   rf   )r(   rb   rc   r1   s   &&& r!   rf   #AsyncAdapt_dbapi_connection.executec  s      y-r$   c                    V ^8  d   QhRRRR/# )r   r   r   r   r   r   )r    s   "r!   r"   r6  m  s     0 0y 0X 0r$   c                	\    \         P                  ! 4       pVP                  V^,          4      h)r   )sysexc_infowith_traceback)r(   r   rF  s   && r!   r   -AsyncAdapt_dbapi_connection._handle_exceptionm  s"    <<>""8A;//r$   c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r6  r  s     * *$ *r$   c                	     V P                  V P                  P                  4       4       R #   \         d   pT P	                  T4        R p?R # R p?ii ; ir&   )r   r   r5   r   r   r(   r   s   & r!   r5   $AsyncAdapt_dbapi_connection.rollbackr  sC    	*KK((1134 	*""5))	*   )- AAAc                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r6  x  s     * * *r$   c                	     V P                  V P                  P                  4       4       R #   \         d   pT P	                  T4        R p?R # R p?ii ; ir&   )r   r   r)   r   r   rK  s   & r!   r)   "AsyncAdapt_dbapi_connection.commitx  sC    	*KK((//12 	*""5))	*rM  c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   r6  ~  s     . .t .r$   c                	X    V P                  V P                  P                  4       4       R # r&   )r   r   r^   r'   s   &r!   r^   !AsyncAdapt_dbapi_connection.close~  s    D$$**,-r$   )r   r   r5  )r5  r   )Fr&   )rD   rE   rF   rG   r   r>  r  r=  staticmethodr   r   r  r   r   r1   rf   r   r5   r)   r^   rI   r   r$   r!   r   r   N  sI    )K/N*%F+I''-
*0
**. .r$   r   c                  *    ] tR tRtRt]! ]4      tRtR# )#AsyncAdaptFallback_dbapi_connectioni  r   N)	rD   rE   rF   rG   r  rT  r   r   rI   r   r$   r!   rV  rV    s    I.)Fr$   rV  c                  N    ] tR tRtRtRtR R ltR R ltR R ltR	 R
 lt	Rt
R# )AsyncAdapt_terminatei  zAMixin for a AsyncAdapt_dbapi_connection to add terminate support.c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   !AsyncAdapt_terminate.__annotate__  s     * *4 *r$   c                	Z   \        4       '       d7    V P                  \        P                  ! V P	                  4       4      4       R # V P                  4        R #   T P                  4        d=   pT P                  4        \        T\        P                  4      '       d   h  R p?R # R p?ii ; ir&   )	r   r   r8  shield_terminate_graceful_close_terminate_handled_exceptions_terminate_force_close
isinstanceCancelledError)r(   es   & r!   	terminateAsyncAdapt_terminate.terminate  s~    ==GNN4+I+I+KLM '') 557 	 ++-a!7!788 9	s   3A B*.1B%%B*c                   V ^8  d   QhRR/# )r   r   zTuple[Type[BaseException], ...]r   )r    s   "r!   r"   rZ    s     G G/N Gr$   c                L    \         P                  \         P                  \        3# )zLReturns the exceptions that should be handled when
calling _graceful_close.
)r8  TimeoutErrorra  OSErrorr'   s   &r!   r^  2AsyncAdapt_terminate._terminate_handled_exceptions  s     $$g&<&<gFFr$   c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   rZ    s     " " "r$   c                   "   \         h5i)z"Try to close connection gracefullyNotImplementedErrorr'   s   &r!   r]  .AsyncAdapt_terminate._terminate_graceful_close  s     !!s   	c                   V ^8  d   QhRR/# r   r   )r    s   "r!   r"   rZ    s     " " "r$   c                    \         h)zTerminate the connectionrl  r'   s   &r!   r_  +AsyncAdapt_terminate._terminate_force_close  s    !!r$   r   N)rD   rE   rF   rG   rH   r  rc  r^  r]  r_  rI   r   r$   r!   rX  rX    s$    KI*(G"" "r$   rX  ))rH   
__future__r   r8  r   rE  typingr   r   r   r   r   r   r	   r
   r   r   enginer   utilr   util.concurrencyr   r   r   util.typingr   engine.interfacesr   r   r   r   r   r   r/   r   r   r  r   rV  rX  r   r$   r!   <module>ry     s    F "   
             &  - ) * ";<=/"=X =*53 53p4 4p pf!8 61."3 1.h**E *%" %"r$   