ޠj=SSKJr SSKJr SSKJr SSKrSSKrSSKrSSKJ r SSK r SSK r SSK r SSK r SSKrSSKJr SSKJr SSKrSSKrSSKJr S S KJr S S KJr S S KJr S SKJr S SKJr S SKJr S SKJr S SKJ r S SKJ!r! S SKJ"r" S SK#Jr S SK$J%r% S SK&J'r' S SK&J(r( S SK&J)r) S SK&J*r* \)(dSr+\+=r,r-O\R\r,Sr-Sr/Sr0S8Sjr1S r2"S!S"\35r4S#r5S$r6S%r7S&r8S'r9S(r:\'S)5r;S*rS9S-jr?S.r@"S/S0\A5rBS1rCS:S3jrDS4rES5rFS6rG\RS2S;S7jj5rIg)<) annotations)deque) namedtupleN)chain) getsizeof)mkstemp)Any)config)mock)inspect) Connection)Column)DropConstraint) DropTable)ForeignKeyConstraint)MetaData)Tableschema)Integer decorator) defaultdict)has_refcount_gc)inspect_getfullargspeccX[R"5 [R"5 gN)gccollect)argss Q/var/www/html/gaurav/venv/lib/python3.13/site-packages/sqlalchemy/testing/util.pynon_refcount_gc_collectr$0s  cgrr'r%r#lazy_gcr(9s r%c#^# [SSS/5n[S[RS-5H mU"[RU4Sj5v M" g7f)Npicklersloadsdumpsr c2>[R"UT5$r)pickler,)dprotocols r#picklers..Asa)Br%)rranger/HIGHEST_PROTOCOLr+)ntr1s @r#r*r*=sE J' 2 3B"f559:BCC;sAAc [S5up#[R"US5n[R"X5 SSS5 [ [ R5n[RRS5(a"UR[RS5 [R"[ RSXR[RS5/[R [R 0[RES[R"R%U50ES9n[R&"U5 UR(S:wa%[+S UR,R/S S 9-5eUR0R35$!,(df  GNf=f![R&"U5 f=f) apickle ``obj`` to a file, then unpickle it in a new interpreter. ``code`` is Python source run by that interpreter, which receives the name of the pickle file as ``sys.argv[1]``. The new interpreter has the current ``sys.path``, so that the SQLAlchemy under test, as well as the ``test`` package, are importable. Returns the stripped stdout of the subprocess; a non-zero exit status fails the test, reporting its stderr. pklwbN PYTHONPATHz-c/)stdoutstderrenvrzsubprocess failed: %sreplace)errors)rosfdopenr/dumplistsyspathenvirongetappend subprocessrun executabler?sepPIPEpathsepjoinunlink returncodeAssertionErrorr=decoder<strip)objcodefdfilenamefile_partsprocs r#unpickle_in_subprocessr]Ds55>LB YYr4 E KK #!SXX ::>>, ' ' LLL1 2~~ ^^T4)9)9"&&#)F G????D2::D|RZZ__U-CD   ( ! #dkk&8&8 &8&J J   ;;   )!  (s"F.FC:F. F+&F..Gc*[R"XS9$)N)k)randomchoices) populationr_s r#random_choicesrcjs >>* **r%c[U[5(a [X5$U[R"SSU--5-R [R 5[SU5- $)N10 ) isinstancefloatrounddecimalDecimal to_integral ROUND_FLOORpow)valueprecs r# round_decimalrrns]%U!! GOOC#*$45 5 B B  B  r%c8\rSrSrSrSrSrSrSrSr Sr g ) RandomSetxc[[RU55n[R"U5 [ U5$r)rDset__iter__r`shuffleiter)selfls r#rxRandomSet.__iter__ys* d# $qAwr%c[R"S[U5S- 5n[[R U55UnUR U5 U$)Nrr )r`randintlenrDrwrxremove)r{indexitems r#pop RandomSet.pop~sCq#d)a-0CLL&'. D r%c>[[RX55$r)rtrwunionr{others r#rRandomSet.unions4/00r%c>[[RX55$r)rtrw differencers r#rRandomSet.differences455r%c>[[RX55$r)rtrw intersectionrs r#rRandomSet.intersections))$677r%c[U5$r)rt)r{s r#copyRandomSet.copys r%r'N) __name__ __module__ __qualname____firstlineno__rxrrrrr__static_attributes__r'r%r#rtrtxs   168r%rtc[[5nUHup4X#RU5 M [U5HupVXSHnXbU;dM g M g)zATrue if the given sorting conforms to the given partial ordering.NFT)rrwadd enumerate)tuplessorted_elementsdepsparentchildinodens r#conforms_partial_orderingrs[ s D   _- $AAw%. r%c^^[[5mUHup#TURU5 M UU4Sjm[T"U55$)Nc3># [U5S:Xa[U5v gUHPn[U5RU/5nUR TU5(aM9T"U5H nU/U-v M MR g7f)Nr )rrDrwrr)elementselemsubset sub_ordering_all_orderingsedgess r#r-all_partial_orderings.._all_orderingssm x=A x.  X114&9**5;77(6v(> #f|33)?!s AA8A8)rrwrrz)rrrrrrs @@r#all_partial_orderingsrsB  E  e   4 x( ))r%cXlU$![aE [R"URUR XR UR5nU$f=f)aKReturn a function with a given __name__. Will assign to __name__ and return the original function if possible on the Python implementation, otherwise a new function will be constructed. This function should be phased out as much as possible in favor of @decorator. Tests that "generate" many named tests should be modernized. )r TypeErrortypes FunctionType__code__ __globals__ __defaults__ __closure__)fnnames r#function_namedrsT  I     KK  I  s A AAcUR5nU"U/UQ70UD6nURSSS5 U$! [R"5nUR"U6nU(deUs$=f)zRun the given function under the given contextmanager, simulating the behavior of 'with' to support older Python versions. This is not necessary anymore as we have placed 2.6 as minimum Python version, however some tests are still using this structure. N) __enter____exit__rEexc_info)ctxrargkwrVresultrraise_s r#run_as_contextmanagerrsh --/C C$#$$ T4& <<>x( Ms 30A%cBUVs1sHn[U5iM sn$s snf)zConverts the results of sql execution into a plain set of column tuples. Useful for asserting the results of an unordered query. tuple)resultsrows r#rowsetrs #* *'3E#J' ** *scU5err')msgs r#failrs #5r%cxSSKJn [R"5nUSn[ USS5nXElU"U0UD6UR 5 URRnU(a0[XG5 UR5R5 Xel$[U[R5 Xel$!UR 5 URRnU(a0[XG5 UR5R5 Xelf[U[R5 Xelf=f)zlProvide bound MetaData for a single test, dropping afterwards. Legacy; use the "metadata" pytest fixture. r )fixturesrmetadataN)rrrgetattrrclose_all_sessionsbase_connection_fixture_connectiondrop_all_tables_from_metadataget_transactioncommitr db)rr"rrrr{ prev_metacfcs r#provide_metadatars H 7Dj$/IM"42 ##%mm::  *( 8    ! ( ( *"  *(FII >! # ##%mm::  *( 8    ! ( ( *"  *(FII >! s B::A?D9c X^[5nUHmURT5 M [U5n[R"UV^s/sH5mSR U4SjU554[ U4SjU55-PM7 snSS[U5--SR U5S.6$s snf)aA facade around @testing.combinations() oriented towards boolean keyword-based arguments. Basically generates a nice looking identifier based on the keywords and also sets up the argument names. E.g.:: @testing.flag_combinations( dict(lazy=False, passive=False), dict(lazy=True, passive=False), dict(lazy=False, passive=True), dict(lazy=False, passive=True, raiseload=True), ) def test_fn(lazy, passive, raiseload): ... would result in:: @testing.combinations( ("", False, False, False), ("lazy", True, False, False), ("lazy_passive", True, True, False), ("lazy_passive", True, True, True), id_="iaaa", argnames="lazy,passive,raiseload", ) def test_fn(lazy, passive, raiseload): ... _c3X># UH nTRUS5(dMUv M" g7fFNrH.0r_r0s r# $flag_combinations..?s9Aq%aas* *c3F># UHnTRUS5v M g7frrrs r#rr@s2TAEE!UOOTs!ra,)id_argnames)rwupdatesortedr combinationsrPrr)rkeysr0s `r#flag_combinationsrs> 5D  A $^UU4SjnST-UlU$)Nc>T"S0UD6T$)Nr'r')rlambda_arg_setsposs r#fixture.create_fixture..fixtureNs"(R(- -r%z fixture_%3.3d)r)rrrs` r#create_fixture+lambda_combinations..create_fixtureMs .+S0r%)rr Mockr rr4r)rrr"rarg_setsrrs` r#lambda_combinationsrHs !/ 2DQ @ @AH   (-c(m(< =(<1>!  (< = AC !A >s A<$Bc [U5SnUVs0sHo3URU5_M nn[UR5nUR U5 [ R "URU5nU"S0UD6$s snf)zGiven a no-arg lambda and a namespace, return a new lambda that has all the values filled in. This is used so that we can have module-level fixtures that refer to instance-level variables using lambdas. rr')rrdictrrrrr)__fnrpos_argsr pass_pos_argsglbnew_fns r#resolve_lambdarYsv&d+A.H19:#"&&+%M: t CJJrN    s 3F  "M "" ;sA>c^U4SjnU$)z&Provide MetaData for a pytest fixture.cF>^U4Sjn[R"TS9"U5$)Nc3"># [R"5=olT"X5nUR[R 5 Uv UR [R 5 g!UR [R 5 f=f7fr)rrr create_allr rdrop_all)r{rrrs r#run_ddl3metadata_fixture..decorate..run_ddlnsc'-'8 8H} -D+##FII. !!&)),!!&)),sB+A+ B+!B  B)scope)r r)rrddls` r#decorate"metadata_fixture..decoratems -~~C(11r%r')r r s` r#metadata_fixturerjs 2 Or%c&^[U4Sj5nU$)zaForce the given table names to be dropped after test complete, isolating for foreign key cycles c>U"U0UD6[[R[[R5TS9 $![[R[[R5TS9 f=f)N) include_names)drop_all_tablesr rr)rr"rnamess r#goforce_drop_names..gosG Pt?r? FIIwvyy'9 OOFIIwvyy'9 Os ;2A-r)rrs` r#force_drop_namesr~s PP Ir%c(\rSrSrSrSrSr\rSrg)adictiz,Dict keys available as attributes. Shadows.cVX$![a [RX5s$f=fr)KeyErrorr__getattribute__)r{keys r#radict.__getattribute__s/ 49  4((3 3 4s ((cF[UVs/sHo UPM sn5$s snfrr)r{rrs r#__call__adict.__call__s!404C3i40110s r'N) rrrr__doc__rrget_allrr'r%r#rrs64 2Gr%rc^^SSKJm UU4Sjn[U[5(d"UR 5nU"U5 SSS5 gU"U5 g!,(df  g=f)Nr )enginesc>TRRU5 URR(d1SSKJn UR SSS9 TRU5 SSS5 gTRU5 g!,(df  g=f)Nr ) assertionszCan't sort tablesF)assert_)testing_reaperprepare_for_drop_tablesdialectsupports_alterrr&expect_warningsr) connectionr&r$rs r#r)drop_all_tables_from_metadata..gosv66zB!!00 $++#U,!!*-   j ) s A;; B )rr$rhrbegin)rengine_or_connectionrr-r$s` @r#rrsL * *J 7 7 ! ' ' )Z zN* )  * )s A Arc Ub [U5nUbUS:XdS5eU4nUR5n[URUS95GHupgU(aAUb USU;aMUR [ [ US[5USS955 MNU(dMWURR(dMtUHupUb USU;aM[ US[5[S[5[S[5USS9n UR [[U RR/U RR /U S 955 M GM SSS5 g!,(df  g=f) Nrz2consider_schemas and schema are mutually exclusive)consider_schemasr rrxy)r)rwr/reversed%sort_tables_on_foreign_key_dependencyexecuterrrr*r+rrrrcr3r4) engine inspectorrr2rconn table_keyfkcst_keyfkctbs r#rrsd M*  $   @ ? @ #9 4'  ; ;!1 <  OI !-!! M9 ilHJy|L ~~44"&JE%1!!HM9 a sG,sG,$Qx BLL&0"$$&&BDDFF8#N#''  sA,E*"B?E** E8c&^[U4Sj5nU$)Nc`>U"U0UD6TR5 $!TR5 f=fr)_clear)rrr event_clss r#r !teardown_events..decorates, s>b>    I   s-r)rDr s` r#teardown_eventsrFs Or%c ^^^^Sn[[[[[[[U[ [[ [0m[ 5m[S5mUUUU4SjmT"U5$)zReturns the approximate memory footprint an object and all of its contents. source: https://code.activestate.com/recipes/577504/ cJ[R"UR55$r)r from_iterableitems)r0s r# dict_handler total_size..dict_handlers""1779--r%rc >[U5T;agTR[U55 [UT5nTR5H6up#[ X5(dMU[ [ TU"U555- n U$ U$)Nr)idrrrJrhsummap)ostyphandler all_handlers default_sizeseensizeofs r#rXtotal_size..sizeofsu a5D= A a &(..0LC!!!SVWQZ011 1r%)rrzrDrrrw frozensetr)rQrKrUrVrWrXs @@@@r# total_sizer[sW. t d t l T4 L 5DQ ))timer skip_test)secondscleanupnowsecs r#skip_if_timeoutrk3s ))+C ))+ C }  I   &s3i{7)1E     &s3i{7)1E s7BA! B! BB)r )function)NrN)rgrirhr )J __future__r collectionsrr contextlibrkr itertoolsrrAr/r`rJrErtempfilerrertypingr rr r rr9rrrrrrrrsql sql.sqltypesrutilrrrrr$ gc_collectr(r!r*r]rcrrrwrtrrrrrrrrrrrrrrrrrFr[rbcontextmanagerrkr'r%r#rxsI#"    #)"")32JJ D#L+2 *$(2+ (" ("V.b"#"(  D !4  5p#L,   r%