ó
    Ð]ju  ã                  óÄ   • 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 Pipeline object implementation.
é    )ÚannotationsN)ÚTracebackType)ÚTYPE_CHECKINGÚAnyé   )Úerrors)ÚSelf)ÚBasePipeline)Ú
ConnectionÚpsycopgc                  ó8   • \ rS rSrSS jr        SS jrSrg)Ú
_DummyLocké   c                ó   • g ©N© ©Úselfs    ÚN/home/mande/repo/quber/.venv/lib/python3.13/site-packages/psycopg/_pipeline.pyÚ	__enter__Ú_DummyLock.__enter__   s   € Øó    c                ó   • g r   r   )r   Úexc_typeÚexc_valÚexc_tbs       r   Ú__exit__Ú_DummyLock.__exit__   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   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$ )ÚPipelineé(   z/Handler for (sync) connection in pipeline mode.r   úConnection[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   r/   ÚPipeline.__init__.   s%   ø€ Ü‰Ñ˜ÔÞ%-”Z“\ˆ�
°4·9±9ˆ�
r   c                óþ   •  U R                      U R                  R                  U R                  5       5        SSS5        g! , (       d  f       g= f! [        R
                   a  nUR                  S5      eSnAff = f)z[Sync the pipeline, send any pending command and receive and process
all available results.
N)r1   r,   ÚwaitÚ	_sync_genÚeÚ_NO_TRACEBACKÚwith_traceback)r   Úexs     r   ÚsyncÚPipeline.sync2   sS   € ð	*Ø—“Ø—
‘
—‘ §¡Ó 0Ô1÷ —–ûä�‰ó 	*Ø×#Ñ# DÓ)Ð)ûð	*ús3   ‚A Ž*A¸A Á
AÁA ÁA ÁA<Á&A7Á7A<c                ó¦   • U R                      U R                  R                  U R                  5       5        S S S 5        U $ ! , (       d  f       U $ = fr   )r1   r,   r7   Ú
_enter_genr   s    r   r   ÚPipeline.__enter__<   s7   € Ø�Z‹ZØ�J‰J�O‰O˜DŸO™OÓ-Ô.÷ àˆ÷ ŒZàˆús   �*AÁ
Ac                ó|  •  U R                      U R                  R                  U R                  5       5        S S S 5        U R                  U5        g ! , (       d  f       N = f! [         a8  nU(       a  [
        R                  SX5         S nANOUR                  S 5      eS nAff = f! U R                  U5        f = f)Nz error ignored terminating %r: %s)	r1   r,   r7   Ú	_exit_genÚ	ExceptionÚloggerÚwarningr;   Ú_exit)r   r   r   r   Úexc2s        r   r   ÚPipeline.__exit__A   s„   € ð
	 Ø—“Ø—
‘
—‘ §¡Ó 0Ô1÷ ð �J‰J�wÕ÷ •ûäó 	0æÜ—‘ÐAÀ4×NÑNà×)Ñ)¨$Ó/Ð/ûð	0ûð �J‰J�wÕúsQ   ‚A# Ž*A¸A# Á
A ÁA# ÁB( Á A# Á#
B%Á-B Â
B( ÂB Â B%Â%B( Â(B;)r1   )F)r2   r+   r3   Úboolr    r!   r   )r    r	   r"   )r#   r$   r%   r&   Ú__doc__Ú__annotations__r/   r=   r   r   r'   Ú__classcell__)r4   s   @r   r)   r)   (   sU   ø‡ Ù9à€JØÓ÷=ñ =ô*ôð
 à,ð ð &ð ð %ð	 ð
 
÷ ò  r   r)   )rK   Ú
__future__r   ÚloggingÚtypesr   Útypingr   r   Ú r   r9   Ú_compatr	   Ú_pipeline_baser
   Ú
connectionr   Ú	getLoggerrE   r   r)   r   r   r   Ú<module>rW      sM   ðñõ #ã Ý ß %å Ý Ý (æÝ&à	×	Ò	˜9Ó	%€÷ñ ô) ˆ|õ ) r   