]j %SrSSKJr SSKrSSKJrJrJr SSKJ r SSK J r SSK J r SS KJrJr SS KJr SS KJrJrJr SS KJr \(aSS KJr SSKJrJr SSKJr SSK J!r! Sr"S\#S'\ RHRJr%\ RHRLr&\ RNRPr(\ RRRTr*\RV"S5r,"SS5r-g)z commands pipeline management ) annotationsN) TYPE_CHECKINGAny TypeAlias)deque)errors)pq)PipelineCommandPQGen)connection_summary) fetch_manypipeline_communicatesend) capabilities)PGresult)KeyPrepare) BaseCursor)BaseConnectionzEtuple[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)_connpgconnrr rrrlevel)selfconns S/home/mande/repo/quber/.venv/lib/python3.13/site-packages/psycopg/_pipeline_base.py__init__BasePipeline.__init__,s9 kk "?35!-02 cURRSURR3n[URR 5nSUSUS[ U5SS3$)N.< z at 0xx>) __class__ __module__ __qualname__r rr id)r"clsinfos r$__repr__BasePipeline.__repr__3s]**+1T^^-H-H,IJ!$**"3"343%qfRXaL22r'cV[R"URR5$)N)r PipelineStatusr pipeline_statusr"s r$statusBasePipeline.status8s  !B BBBc## UR(dgU(a7URR5 [UR5ShvN SnUR(ad[ UR5ShvN =n(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) rr send_flush_requestrrr`rarKrb)r"rVrdrerfrPs r$rZBasePipeline._fetch_gen|s    KK * * ,DKK( ( ( +5dkk+B BCGC&&..0F $%%f6  O ! )!C77 $$ #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_ERRORrKerror_from_resultr _encodingPIPELINE_ABORTEDPipelineAbortedr _preparedvalidate_check_results _set_results) r"rfreresultcursorprepinfokeyprepnames r$raBasePipeline._process_resultss >IV}} +))&;;;P;PQQ"22''(:;;3 & F"*4 &&//4I  ! !' *    (r'cURRURR5 URRS5 g)z#Enqueue a PQpipelineSync() command.N)rappendr pipeline_syncrr9s r$rXBasePipeline._enqueue_syncs4 !!$++";";<   &r')rrr!r rN)r#zBaseConnection[Any]returnNone)rstr)rzpq.PipelineStatus)rbool)r PQGen[None])rPzBaseException | Nonerr)rVrrr)rfrrezlist[PGresult]rr)rr)__name__r/r0__firstlineno____annotations__r%r4propertyr: classmethodr>rFrRrEr]rYrZrarX__static_attributes__r'r$rr(sh))&&3 >>++  40 3 >).'r'r).__doc__ __future__rloggingtypingrrr collectionsrr rKr abcr r pq.miscr generatorsrrr _capabilitiesrpq.abcr _preparingrr _cursor_baser_connection_baserrr ExecStatusrmrp ConnStatusrITransactionStatusrD getLoggerrMrrr'r$rs #00''>>' ((0Lymm'' ==11mm   $ $   9 %M'M'r'