
    3fi              	         U d Z ddlmZ ddlZej                  dk\  rddlmZ nddlmZ ej                  dk\  rddlmZ nddlmZ ddl	Z	ddl
mZ  e eee	j                   j#                  dd	      dd	             Zed
k\  re	j&                  Ze	j*                  Zn* G d de	j&                        Z G d de	j*                        Zg dZ	 ej0                  Zded<   y# e$ r  G d dej6                        ZeZY yw xY w)z7
compatibility functions for different Python versions
    )annotationsN)      )Self)r      )TypeVar.   )r   r   c                  $     e Zd ZdZd fdZ xZS )AsyncPoolConnectionz_
        Thin wrapper around the psycopg async connection to improve pool integration.
        c                   K   t        | dd       x}r|j                  |        d {    y t        |           d {    y 7 7 wN_poolgetattrputconnsupercloseselfpool	__class__s     R/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/psycopg_pool/_compat.pyr   zAsyncPoolConnection.close%   sK     tWd33t3 ll4((( gmo%%	 ) &s   $AAAAAAreturnNone__name__
__module____qualname____doc__r   __classcell__r   s   @r   r   r       s    		& 	&    r   c                  $     e Zd ZdZd fdZ xZS )PoolConnectionzY
        Thin wrapper around the psycopg connection to improve pool integration.
        c                d    t        | dd       x}r|j                  |        y t        |           y r   r   r   s     r   r   zPoolConnection.close4   s0    tWd33t3 T" r$   r   r   r#   s   @r   r&   r&   /   s    		  	 r$   r&   )r   r&   r   r   ztype[e.OperationalError]ConnectionTimeoutc                      e Zd Zy)DummyConnectionTimeoutN)r   r   r     r$   r   r*   r*   L   s    r$   r*   )r!   
__future__r   sysversion_infotypingr   typing_extensionsr   psycopgpsycopg.errorserrorsetuplemapint__version__splitPSYCOPG_VERSIONAsyncConnectionr   
Connectionr&   __all__r(   __annotations__AttributeErrorOperationalErrorr*   r+   r$   r   <module>rA      s    # 
w&w)  C!4!4!:!:3!B2A!FGHf!11''N&g55 & ++   /232E2E/E /!3!3  //s   	C C:9C: