(phi$%SrSSKJr SSKrSSKJr SSKJrJr SSK J r SSK J r SS K JrJr SS KJrJrJr SS KJr SS KJrJrJr SS KJr \(a&SSKJr SSKJr SSK J!r!J"r" SSK#J$r$ SSK%J&r& SSK'J(r( Sr)S\*S'\ RVRXr,\ RVRZr-\ R\R^r/\ R`Rbr1\Rd"S5r3"SS5r4"SS\45r5"SS\45r6g)z commands pipeline management ) annotationsN) TracebackType)Any TYPE_CHECKING)pq)errors)PipelineCommandPQGen)DequeSelf TypeAlias)connection_summary)pipeline_communicate fetch_manysend) capabilities)PGresult) Connection)KeyPrepare) BaseCursor)BaseConnection)AsyncConnectionzEtuple[BaseCursor[Any, Any], tuple[Key, Prepare, bytes] | None] | Noner PendingResultpsycopgc\rSrSr%S\S'S\S'SSjrSSjr\SSj5r\ SS j5r SS jr SS jr SS jr SS jrSSjrSSjrSSjrSSjrSrg) BasePipeline+zDeque[PipelineCommand] command_queuezDeque[PendingResult] result_queuecXlURUl[["5Ul[[ "5UlSUlg)Nr)_connpgconnr r r rr!level)selfconns D/var/www/html/venv/lib/python3.13/site-packages/psycopg/_pipeline.py__init__BasePipeline.__init__/s9 kk "?35!-02 cURRSURR3n[URR 5nSUSUS[ U5SS3$)N.< z at 0xx>) __class__ __module__ __qualname__rr#r$id)r&clsinfos r(__repr__BasePipeline.__repr__6s]**+1T^^-H-H,IJ!$**"3"343%qfRXaL22r+cV[R"URR5$N)rPipelineStatusr$pipeline_statusr&s r(statusBasePipeline.status;s  !s r( _enter_genBasePipeline._enter_genDsl!!- ::? KK + + -   4;;#A#AV#K~~' ' ' a  (sBB!BB!cbU=RS-slURS:Xa;URR[:waURR 5 ggg![ R a8nU(a[RSX5 SnAgURS5eSnAff=f)Nrrzerror ignored exiting %r: %s) r%r$r?BADexit_pipeline_modeeOperationalErrorloggerwarningwith_traceback)r&excexc2s r(_exitBasePipeline._exitRs a ::?t{{11S8 4 ..0 9?%% 4NN#A4NN--d33 4sA""B.6B)B))B.c## UR5 UR5ShvN URSS9ShvN gNN7f)NFflush _enqueue_sync_communicate_gen _fetch_genr>s r(rJBasePipeline._sync_gen`s? ((***???/// +/s$AAAAAAc## UR5 UR5ShvN URSS9ShvN gNN!URSS9ShvN f=f7f)zO Exit current pipeline by sending a Sync and fetch back all remaining results. NTrZr\r>s r( _exit_genBasePipeline._exit_genesX 3    ,,. . .T2 2 2 / 2tT2 2 2sGA%#AAAA%AA%AA%A"AA""A%c#2# [URUR5ShvN nSnUH/nURR 5nUR XC5 M1 UbUegNA![ RanUcUnSnAMZSnAM`SnAff=f7f)zaCommunicate with pipeline to send commands and possibly fetch results, which are then processed. N)rr$r r!popleft_process_resultsrPError)r&fetched exceptionresultsqueuedrUs r(r^BasePipeline._communicate_genos2$++t?Q?QRR G&&..0F $%%f6  O !S 77 $$ #I% $s9$BA(%B A* B*B>B BBBc## UR(dgU(a7URR5 [UR5ShvN SnUR(ad[ UR5ShvN nU(dO?URR 5nUR XC5 UR(aMdUbUegNNS![RanUcUnSnAN;SnAff=f7f)a.Fetch available results from the connection and process them with pipeline queued items. If 'flush' is True, a PQsendFlushRequest() is issued in order to make sure results can be fetched. Otherwise, the caller may emit a PQpipelineSync() call to ensure the output buffer gets flushed before fetching. N) r!r$send_flush_requestrrrerfrPrg)r&r[rirjrkrUs r(r_BasePipeline._fetch_gens    KK * * ,DKK( ( ( !+DKK!88G&&..0F $%%f6  O ! )977 $$ #I $sTA C:C/C:>C?&C:&C7C: C:C:C7(C2-C:2C77C:cUckUunUR[:Xa([R"X0RR S9eUR[ :Xa[R"S5egUupEU(a+UupgnURRRXgX5 URU5 URU5 g)aJProcess a results set fetched from the current pipeline. This matches 'results' with its respective element in the pipeline queue. For commands (None value in the pipeline queue), results are checked directly. For prepare statement creation requests, update the cache. Otherwise, results are attached to their respective cursor. N)encodingzpipeline aborted) r? FATAL_ERRORrPerror_from_resultr$ _encodingPIPELINE_ABORTEDPipelineAbortedr# _preparedvalidate_check_results _set_results) r&rkrjresultcursorprepinfokeyprepnames r(rfBasePipeline._process_resultss >IV}} +))&;;;P;PQQ"22''(:;;3 & F"*4 &&//4I  ! !' *    (r+cURRURR5 URRS5 g)z#Enqueue a PQpipelineSync() command.N)r appendr$ pipeline_syncr!r>s r(r]BasePipeline._enqueue_syncs4 !!$++";";<   &r+)r#r r%r$r!N)r'zBaseConnection[Any]returnNone)rstr)rzpq.PipelineStatus)rbool)r PQGen[None])rUBaseException | Nonerr)r[rrr)rkrrjzlist[PGresult]rrrr)__name__r3r4__firstlineno____annotations__r)r8propertyr? classmethodrCrKrWrJrbr^r_rfr]__static_attributes__r+r(rr+si))&&3 >>++  40 3 @).'r+rcn^\rSrSr%SrSrS\S'S U4SjjrS SjrS SjrSS jr S r U=r $)Pipelinez(Handler for connection in pipeline mode.rConnection[Any]r#c$>[TU]U5 gr;superr)r&r'r2s r(r)Pipeline.__init__ r+cURR URRUR55 SSS5 g!,(df  g=f![R anUR S5eSnAff=f)z[Sync the pipeline, send any pending command and receive and process all available results. Nr#lockwaitrJrP _NO_TRACEBACKrTr&exs r(sync Pipeline.syncsW *  01! *##D) ) *s4A*A A AAAB0BBcURR URRUR55 SSS5 U$!,(df  U$=fr;r#rrrKr>s r( __enter__Pipeline.__enter__s; ZZ__ JJOODOO- . _ s *A  AcURR URRUR55 SSS5 URU5 g!,(df  N =f![a8nU(a[ R SX5 SnANOURS5eSnAff=f!URU5 f=fNz error ignored terminating %r: %s r#rrrb ExceptionrRrSrTrWr&exc_typeexc_valexc_tbrVs r(__exit__Pipeline.__exit__s   01! JJw ! 0A4NN))$//  0 JJw sRA-*AA- A*&A-)B2*A-- B/7B*B2B**B//B22Cr)r'rrrrrr rztype[BaseException] | NonerrrzTracebackType | Nonerr) rr3r4r__doc__rr)rrrr __classcell__r2s@r(rrsP2J *  , & %     r+rcn^\rSrSr%SrSrS\S'S U4SjjrS SjrS SjrSS jr S r U=r $) AsyncPipelinez.Handler for async connection in pipeline mode.rAsyncConnection[Any]r#c$>[TU]U5 gr;rrs r(r)AsyncPipeline.__init__rr+ch# URRIShvN URRUR55IShvN SSS5IShvN gNFNN !,IShvN (df  g=f![R anUR S5eSnAff=f7fr;rrs r(rAsyncPipeline.syncso *zzjjoodnn&6777'7' *##D) ) *sB2BA%B-A+A'A+ BA) B$B2%B'A+)B+B1A4 2 B>BB2BB/B**B//B2c# URRIShvN URRUR55IShvN SSS5IShvN U$NGNN !,IShvN (df  U$=f7fr;rr>s r( __aenter__AsyncPipeline.__aenter__sQ::???**//$//"34 4 4#? # 4#?? sVBA%B-A+A'A+ BA)B'A+)B+B1A4 2 B>Bc# URRIShvN URRUR55IShvN SSS5IShvN URU5 gNWN(N!,IShvN (df  N/=f![a8nU(a[ R SX5 SnAN^URS5eSnAff=f!URU5 f=f7frrrs r( __aexit__AsyncPipeline.__aexit__s zzjjoodnn&6777' JJw '7' 0A4NN))$//  0 JJw sC1BA6B-A<A8A< BA: B$C16B8A<:B<BB  BBCB C C=CCCCC..C1r)r'rrrrrr) rr3r4rrrr)rrrrrrs@r(rrsP8J *  , & %     r+r)7r __future__rloggingtypesrtypingrrrr rPabcr r _compatr r rpq.miscr generatorsrrr _capabilitiesrpq.abcr connectionr _preparingrr _cursor_baser_connection_baserconnection_asyncrrr ExecStatusrrru ConnStatusrNTransactionStatusrI getLoggerrRrrrrr+r(rs #%'++'>>' &((01Lymm'' ==11mm   $ $   9 %N'N'b( |( V% L% r+