(ph*$SrSSKJr SSKrSSKJr SSKJrJrJ r J r SSK J r SSK J r SS K Jr SS KJrJr SS KJr SS KJr \ (a SS KJr SSKJr \ R6R8r\ R:R<r\R>"\ 5r!"SS\"5r#"SS\RH5r%"SS\\5r&"SS\&S5r'"SS\&S5r(g)zC Transaction context managers returned by Connection.transaction() ) annotationsN) TracebackType)AnyGenericIterator TYPE_CHECKING)pq)sql)errors)ConnectionTypePQGen)Self)connection_summary) Connection)AsyncConnectionc4\rSrSrSrSrSS SjjrS SjrSrg) Rollback z Exit the current `Transaction` context immediately and rollback any changes made within this context. If a transaction context is specified in the constructor, rollback enclosing transactions contexts up to and including the one specified. psycopgNcXlgN transaction)selfrs F/var/www/html/venv/lib/python3.13/site-packages/psycopg/transaction.py__init__Rollback.__init__+s&cPURRSUR<S3$)N()) __class__ __qualname__rrs r__repr__Rollback.__repr__.s'..--.a0@0@/C1EErrr)rz%Transaction | AsyncTransaction | Nonereturnstr)__name__ __module__r$__firstlineno____doc__rr&__static_attributes__rrrr sJ'Frrc\rSrSrSrSrg)OutOfOrderTransactionNesting2z)Out-of-order transaction nesting detectedr0N)r+r,r$r-r.r/r0rrr2r22s3rr2c\rSrSrSSSjjr\SSj5rSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSSjrSrg)BaseTransaction6NcXlURRUlU=(d SUlX0lS=UlUlSUlSUlg)NF)_connpgconn_savepoint_nameforce_rollback_entered_exited_outer_transaction _stack_index)r connectionsavepoint_namer=s rrBaseTransaction.__init__7sK  jj'' -3,',,  "'rcUR$)zF The name of the savepoint; `!None` if handling the main transaction. )r<r%s rrCBaseTransaction.savepoint_nameEs###rc \URRSURR3n[UR5nUR (dSnOUR (dSnOSnUR(aUR<S3OSnSUSUSUS US [U5S S 3 $) N.inactiveactive terminated r8) r#r,r$rr;r>r?rCid)rclsinfostatussps rr&BaseTransaction.__repr__Ns**+1T^^-H-H,IJ!$++.}}FF!F,0,?,?##&a (R3%qAfXRvVBtHQ TypeError_push_savepoint_get_enter_commandsr: _exec_command)rcommands r _enter_genBaseTransaction._enter_gen[sY ==FG G  //1Gzz//8 8 82 8sA%A3'A1( A3c## U(d*UR(dUR5ShvN gURU5ShvN $NN![a e[a n[ R SX5 SnAgSnAff=f7f)NFz#error ignored in rollback of %s: %s)r= _commit_gen _rollback_genr2 Exceptionloggerwarning)rexc_typeexc_valexc_tbexc2s r _exit_genBaseTransaction._exit_gendsx t22'') ) ) #'#5#5g#>>? * ?/   DdQ sJ,B AB A A A B AB&B<B BB c## URS5nSUlU(aUeUR5H&nURR U5ShvN M( gN 7f)NcommitT)_pop_savepointr?_get_commit_commandsr:rZ)rexr[s rr_BaseTransaction._commit_gen}sR   * H002Gzz//8 8 83 8sAA!A A!c#X# [U[5(a![RURS3SS9 UR S5nSUlU(aUeUR5H&nURRU5ShvN M( URRR5 URRRUR5ShvN [U[5(a!UR(aURULaggNN=7f)Nz: Explicit rollback from: T)exc_inforollbackF) isinstancerrbdebugr:rlr?_get_rollback_commandsrZ _preparedclear maintain_genr)rrernr[s rr`BaseTransaction._rollback_gens gx ( ( LLDJJ<'ABTL R   , H224Gzz//8 8 85 ""$::''44TZZ@@@ gx ( (&&'*=*=*E 9 As%B D* D& AD**D(+?$**%   &#..)=)=>?$**%   " "zz33 33  #sDDc~URR[:HUlUR(aURR (aeO2UR (d!SURR S-3UlURR UlUR=R S- slg)z Push the transaction on the connection transactions stack. Also set the internal state of the object and verify consistency. _pg3_r N)r;transaction_statusIDLEr@r:rr<rAr%s rrXBaseTransaction._push_savepoints #'++"@"@D"H  " "zz33 333'').tzz/K/Ka/O.P'Q$ JJ88 $$)$rcUR=RS-slURRUR:Xag[SUSU35$)za Pop the transaction from the connection transactions stack. Also verify the state consistency. r Nz transaction z at the wrong nesting level: )r:rrAr2)ractions rrlBaseTransaction._pop_savepointsR $$)$ :: ' '4+<+< <+6("?v F  r)r:r>r?r@r<rAr=r;NF)rBr rC str | Noner=bool)r)rr()r)z PQGen[None])rdtype[BaseException] | NonereBaseException | NonerfTracebackType | Noner) PQGen[bool])rerr)r)r)zIterator[bytes])r)None)rr*r)zException | None)r+r,r$r-rpropertyrCr&r\rhr_r`rYrmrurXrlr/r0rrr5r56s&*$ " #  $$ B9,&%   29,  "*&  rr5cT\rSrSrSrSr\S Sj5rS SjrS SjrSr g) TransactionzG Returned by `Connection.transaction()` to handle a transaction block. rcUR$)z&The connection the object is managing.r:r%s rrBTransaction.connectionszzrcURR URRUR55 SSS5 U$!,(df  U$=frr:lockwaitr\r%s r __enter__Transaction.__enter__s; ZZ__ JJOODOO- . _ s *A  AcURR[:XaKURR URR UR XU55sSSS5 $g!,(df  g=frr;rSOKr:rrrhrrdrerfs r__exit__Transaction.__exit__sP ;;   #zzt~~h'PQ!!s +A++ A9r0N)r)Connection[Any]r)rrdrrerrfrr)r) r+r,r$r-r.rrBrrr/r0rrrrsPJ  , & %   rrrcT\rSrSrSrSr\S Sj5rS SjrS SjrSr g) AsyncTransactionizL Returned by `AsyncConnection.transaction()` to handle a transaction block. rcUR$rrr%s rrBAsyncTransaction.connection s zzrc# URRIShvN URRUR55IShvN SSS5IShvN U$NGNN !,IShvN (df  U$=f7frrr%s r __aenter__AsyncTransaction.__aenter__sQ::???**//$//"34 4 4#? # 4#?? sVBA%B-A+A'A+ BA)B'A+)B+B1A4 2 B>BcN# URR[:XacURRIShvN URR UR XU55IShvN sSSS5IShvN $gNINN !,IShvN (df  g=f7frrrs r __aexit__AsyncTransaction.__aexit__se ;;   #zz!ZZ__T^^Hv-VWW''W'sV9B%BB%/B .B/B 2 B%>B ?B%B  B% B"B  B"B%r0N)r)AsyncConnection[Any]rr) r+r,r$r-r.rrBrrr/r0rrrrsPJ  , & %   rrr))r. __future__rloggingtypesrtypingrrrrr8r r r eabcr r_compatrpq.miscrrBrconnection_asyncrTransactionStatusr ConnStatusr getLoggerr+rbrarProgrammingErrorr2r5rrr0rrrs #88&'&1   ]]   8 $FyF$41#5#54m gn-m `/"34<'=>r