o DDi<@sdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z dd lmZer4dd lmZed ZGd d d ZGdddeZdS)z. Psycopg AsyncPipeline object implementation. ) annotationsN) TracebackType) TYPE_CHECKINGAny)errors)Self) BasePipeline)AsyncConnectionpsycopgc@s eZdZdddZdd d Zd S) _DummyLockreturnNonecdSNselfrrP/var/www/Datamplify/venv/lib/python3.10/site-packages/psycopg/_pipeline_async.py __aenter__sz_DummyLock.__aenter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Nonecrrr)rrrrrrr __aexit__sz_DummyLock.__aexit__Nr rrrrrrrr r)__name__ __module__ __qualname__rrrrrrr s r csPeZdZUdZdZded<ddfd d Zdd dZdddZdddZZ S) AsyncPipelinez0Handler for (async) connection in pipeline mode.r AsyncConnection[Any]_connFconn_no_lockboolr rcs(t||rt|_dS|j|_dSr)super__init__r lock_lock)rr%r& __class__rrr)*s zAsyncPipeline.__init__c sz-|j4IdH|j|IdHWdIdHWdS1IdHs'wYWdStjy@}z|dd}~ww)zkSync the pipeline, send any pending command and receive and process all available results. N)r+r$wait _sync_gene _NO_TRACEBACKwith_traceback)rexrrrsync.s2 zAsyncPipeline.syncrc sX|j4IdH|j|IdHWdIdH|S1IdHs%wY|Sr)r+r$r. _enter_genrrrrr8szAsyncPipeline.__aenter__rrrrrrc sz\z*|j4IdH|j|IdHWdIdHn 1IdHs&wYWn!tyM}z|r>td||n|dWYd}~n d}~wwW||dSW||dS||w)Nz error ignored terminating %r: %s) r+r$r. _exit_gen Exceptionloggerwarningr2_exit)rrrrexc2rrrr=s"(  zAsyncPipeline.__aexit__)F)r%r#r&r'r rr)r rr) rr r!__doc____annotations__r)r4rr __classcell__rrr,rr"$s   r")r< __future__rloggingtypesrtypingrrrr0_compatr_pipeline_baser connection_asyncr getLoggerr8r r"rrrrs