
    ,h<                        S r SSKJr  SSKrSSKJr  SSKJrJr  SSK	J
r  SSKJr  SS	KJr  \(       a  SS
KJr  \R$                  " S5      r " S S5      r " S S\5      rg)z.
Psycopg AsyncPipeline object implementation.
    )annotationsN)TracebackType)TYPE_CHECKINGAny   )errors)Self)BasePipeline)AsyncConnectionpsycopgc                  8    \ rS rSrSS jr        SS jrSrg)
_DummyLock   c                   #    g 7fN selfs    R/var/www/html/Ai_home/venv/lib/python3.13/site-packages/psycopg/_pipeline_async.py
__aenter___DummyLock.__aenter__   s        c                   #    g 7fr   r   )r   exc_typeexc_valexc_tbs       r   	__aexit___DummyLock.__aexit__   s
      	r   r   NreturnNoner   ztype[BaseException] | Noner   zBaseException | Noner   zTracebackType | Noner    r!   )__name__
__module____qualname____firstlineno__r   r   __static_attributes__r       r   r   r      s2    , & %	
 
r(   r   c                  r   ^  \ rS rSr% SrSrS\S'   SSU 4S jjjrSS jrSS jr        SS	 jr	S
r
U =r$ )AsyncPipeline$   z0Handler for (async) connection in pipeline mode.r   AsyncConnection[Any]_connc                t   > [         TU ]  U5        U(       a  [        5       U l        g UR                  U l        g r   )super__init__r   lock_lock)r   conn_no_lock	__class__s      r   r0   AsyncPipeline.__init__*   s%    %-Z\
499
r(   c                T  #     U R                    ISh  vN   U R                  R                  U R                  5       5      I Sh  vN   SSS5      ISh  vN   g NF N N	! , ISh  vN  (       d  f       g= f! [        R
                   a  nUR                  S5      eSnAff = f7f)z[Sync the pipeline, send any pending command and receive and process
all available results.
N)r2   r-   wait	_sync_gene_NO_TRACEBACKwith_traceback)r   exs     r   syncAsyncPipeline.sync.   sk     	*zzzjjoodnn&6777 "zz7 "zzz 	*##D))	*s   B(A; AA; -A!AA!
A; AA; B(A; A!A; !A8'A*(A84A; 7B(8A; ;B%B  B%%B(c                   #    U R                    IS h  vN   U R                  R                  U R                  5       5      I S h  vN   S S S 5      IS h  vN   U $  NG N N
! , IS h  vN  (       d  f       U $ = f7fr   )r2   r-   r8   
_enter_genr   s    r   r   AsyncPipeline.__aenter__8   sM     :::**//$//"3444 : 4 ::sV   A<AA<-A!AA!	A<AA<A!A<!A9'A*(A94A<c                  #     U R                    IS h  vN   U R                  R                  U R                  5       5      I S h  vN   S S S 5      IS h  vN   U R                  U5        g  NW N( N! , IS h  vN  (       d  f       N/= f! [         a8  nU(       a  [
        R                  SX5         S nAN^UR                  S 5      eS nAff = f! U R                  U5        f = f7f)Nz error ignored terminating %r: %s)	r2   r-   r8   	_exit_gen	Exceptionloggerwarningr<   _exit)r   r   r   r   exc2s        r   r   AsyncPipeline.__aexit__=   s     
	 zzzjjoodnn&6777 "z JJw "7 "zzz 	0A4NN))$//	0 JJws   C'B A,B -A2A.A2
B A0B C',B .A20B 2B	8A;9B	B C 	B 
CC	3C 8C		CC C$$C')r2   )F)r3   r,   r4   boolr    r!   r   )r    r	   r"   )r#   r$   r%   r&   __doc____annotations__r0   r>   r   r   r'   __classcell__)r5   s   @r   r*   r*   $   sU    :J= =*
 ,  &  %	 
 
   r(   r*   )rL   
__future__r   loggingtypesr   typingr   r    r   r:   _compatr	   _pipeline_baser
   connection_asyncr   	getLoggerrF   r   r*   r   r(   r   <module>rX      sM    #   %   (1			9	%
 
) L ) r(   