Ytj<dZddlmZddlZddlmZddlmZmZddl m Z ddl m Z dd lmZerdd lmZejd ZGd d ZGddeZdS)z. Psycopg AsyncPipeline object implementation. ) annotationsN) TracebackType) TYPE_CHECKINGAny)errors)Self) BasePipeline)AsyncConnectionpsycopgceZdZd dZd d Zd S) _DummyLockreturnNonec KdSNselfs U/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/psycopg/_pipeline_async.py __aenter__z_DummyLock.__aenter__s  exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Nonec KdSrr)rrrrs r __aexit__z_DummyLock.__aexit__s rNrrrrrrrrrr)__name__ __module__ __qualname__rr rrrrrs<          rrcNeZdZUdZdZded<ddfd Zdd ZddZddZxZ S) AsyncPipelinez0Handler for (async) connection in pipeline mode.r AsyncConnection[Any]_connFconn_no_lockboolrrct||rtn|j|_dSr)super__init__rlock_lock)rr*r+ __class__s rr/zAsyncPipeline.__init__*s5 %-}|rt d||n|dYd}~nd}~wwxYw||dS#||wxYw)Nz error ignored terminating %r: %s) r1r)r4 _exit_gen Exceptionloggerwarningr8_exit)rrrrexc2s rr zAsyncPipeline.__aexit__=s z 8 8 8 8 8 8 8 8joodnn&6&6777777777 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 0 0 0 0A4NNNN))$///ONNNN 0 JJw     DJJw    sR A(3AA( A  A(#A $A('C ( B024B+&C +B00C C!)F)r*r(r+r,rrr!)rr r") r#r$r%__doc____annotations__r/r:rr __classcell__)r2s@rr'r'$s::J=======****         rr')rD __future__rloggingtypesrtypingrrrr6_compatr _pipeline_baser connection_asyncr getLoggerr@rr'rrrrPs #"""""%%%%%%%%((((((2111111  9 % %         ) ) ) ) ) L) ) ) ) ) r