Vi9.SSKrSSK7 SSKJr SSKJr SSKJr SSKJr SSKJr SrSS jrSS jr SS jr SS jr "S S\ 5r SSjr"SS\5rg)N)*)Alias)CompoundSelectQuery)Metadata) callable_)__deprecated__c:U(a [U5$[5$N)set)ss f/home/james-whalen/.local/share/pipx/venvs/semgrep/lib/python3.13/site-packages/playhouse/shortcuts.pyr ss1v--c L^^UcSOUnUS:XaSn[T5m[U5nUU4Sjn Ub~TRS5 URH]n [U [5(aTRU 5 M+[U [ 5(dMBURU R 5 M_ 0n [T5m[U5nTU-m[U5n U (aURRR5HupU "U5(aMTRXRRRUR45 URRRHnTRU5 M /n[!X5H#nUR#[%UUUTTUS- S95 M% UX'M URR&HnU "U5(aMUR(R+UR,5n[U[.5(aBU(a;Ub6[!UUR,5n[%UUUTTU[1U45-US- S 9nOSnUU UR,'M U(a6UH0n[!UU5n[3U5(a U"5U U'M+UU U'M2 U(aU(aURR4R5HunnURS :XaM[!U UR5nUT;dUT;aM<T(aUT;aUT;aMQ/nTRU5 [!UUR5nUH#nUR#[%UUUTTUS- S95 M% UU UR'M U $) a Convert a model instance (and any related objects) to a dictionary. :param bool recurse: Whether foreign-keys should be recursed. :param bool backrefs: Whether lists of related objects should be recursed. :param only: A list (or set) of field instances indicating which fields should be included. :param exclude: A list (or set) of field instances that should be excluded from the dictionary. :param list extra_attrs: Names of model instance attributes or methods that should be included. :param SelectQuery fields_from_query: Query that was source of model. Take fields explicitly selected by the query and serialize them. :param int max_depth: Maximum depth to recurse, value <= 0 means no max. :param bool manytomany: Process many-to-many fields. NrFc8>UT;=(d T=(a UT;$r )nexcludeonlys r rmodel_to_dict..'sQ'\Ht/G$Hr __sentinel__)recursebackrefsrr max_depth)rrrrseenr+) _clone_setadd _returning isinstanceFieldr_aliastype_meta manytomanyitemsupdate rel_modelbackref through_modelrefsgetattrappend model_to_dict sorted_fields__data__getnameForeignKeyFieldr rr)modelrrrrr extra_attrsfields_from_queryrr' should_skipitemdata model_classr4m2mfkfaccumrel_objfield field_data attr_nameattr foreign_keyr* descriptor related_querys `` r r0r0s?& 'YIA~ d D[)KHK$  %00D$&&D%(( , 1 D!G d D tOGu+K//557ID4   NNC!4!4!?!? !LM N((..33 C 4E"5/ ]#%#'!m -.0DJ#8&** u   ^^'' 3 e_ - -'%!%4*#%#UH -'!m- " %UZZ'+*$I5),D"&&Y"&Y %G&+kk&:&:&@&@&B "K""c)8 k.A.ABJW$ w(>4/k6ME KK $#E;+>+>?M( ]#%#'!m -.)).D$$ %+'C. Krc URn[URVs/sHoDRU4PM sn5nUR 5GHkupgXcR ;aUR UnSn O>Xe;aXVnSn O2U(a[ XU5 MH[SU<S[U5<S35e[U[5n U (dYU (aR[U[5(a=URURn [ UUR[XU55 MU (ay[U[ ["45(a^UV s/sHn [%UR&X5PM n n U Hn [ XRU5 M [ XRU 5 GMU[ XRU5 GMn U$s snf![a UR5n Nf=fs sn f)NFTzUnrecognized attribute "z" for model class .)r&dictrr+r(combinedsetattrAttributeErrorr%r"r5__rel__r4KeyErrorr*update_model_from_dictlisttuple dict_to_modelr6)instancer;ignore_unknownmetafkrkeyvaluerA is_backrefis_foreign_key rel_instancerow_data instancess r rPrPs >>D > "jj"% >?Hjjl  -- MM#&EJ _MEJ  H5 )  03T(^"EF F$E?;nE41H1H 1'// ;   &|NK MJutUm<<!&' %Hekk8D % '!*  jj(;!* HmmY 7 Hjj% 0C#F OK?* 1$0  1'sG'G G%G"!G"c$[U"5X5$r )rP)r<r;rUs r rSrSs !+- FFrcbURRR5H9up4URU;dX1;aM[ U5(aU"5OUnXQU'M; [ UR56upg[ US9RU5nURX5R5$)a Helper for generating conditional INSERT queries. For example, prevent INSERTing a new tweet if the user has tweeted within the last hour:: INSERT INTO "tweet" ("user_id", "content", "timestamp") SELECT 234, 'some content', now() WHERE NOT EXISTS ( SELECT 1 FROM "tweet" WHERE user_id = 234 AND timestamp > now() - interval '1 hour') Using this helper: cond = ~fn.EXISTS(Tweet.select().where( Tweet.user == user_obj, Tweet.timestamp > one_hour_ago)) iq = insert_where(Tweet, { Tweet.user: user_obj, Tweet.content: 'some content'}, where=cond) res = iq.execute() )columns) r&defaultsr(r4rzipSelectwhere insert_from as_rowcount) clsr;rerAdefaultrYfieldsvaluessqs r insert_whererms2)),,224 :: &w// WU 5$**,'NF   % %e ,B ??2 & 2 2 44rcp^\rSrSrSr\S4\S4\S4\S4\S44rU4SjrS U4S jjrU4S jr S r S r U=r $)ReconnectMixina Mixin class that attempts to automatically reconnect to the database under certain error conditions. For example, MySQL servers will typically close connections that are idle for 28800 seconds ("wait_timeout" setting). If your application makes use of long-lived connections, you may find your connections are closed after a period of no activity. This mixin will attempt to reconnect automatically when these errors occur. This mixin class probably should not be used with Postgres (unless you REALLY know what you are doing) and definitely has no business being used with Sqlite. If you wish to use with Postgres, you will need to adapt the `reconnect_errors` attribute to something appropriate for Postgres. 2006201320144031zMySQL Connection not available.c>[[U] "U0UD6 0UlURHMup4URR U/5 URUR UR55 MO gr )superro__init___reconnect_errorsreconnect_errors setdefaultr/lower)selfargskwargs exc_class err_fragment __class__s r rwReconnectMixin.__init__sl nd,d=f="$'+'<'< #I  " " - -i <  " "9 - 4 4\5G5G5I J(=rc\>Ub [S5 UR[[U]X5$)Nz,"commit" has been deprecated and is a no-op.)r _reconnectrvro execute_sql)r|sqlparamscommitrs r rReconnectMixin.execute_sqls/   I Ju^TF", ,rcH>UR"[[U]/UQ70UD6$r )rrvrobeginr|r}r~rs r rReconnectMixin.begins-u^T@0 $0(.0 0rcU"U0UD6$![anUR5(aUe[U5nXPR;aUe[ U5R 5nURUH nXv;dM O UeUR 5(d UR5 UR5 U"U0UD6sSnA$SnAff=fr ) Exceptionin_transactionr%rxstrr{ is_closedcloseconnect)r|funcr}r~excrexc_reprrs r rReconnectMixin._reconnects )(( ( )""$$ S I 6 66 3x~~'H $ 6 6y A +!B >>##  (( (+ )s" CA!C9AC;CC)rx)NN) __name__ __module__ __qualname____firstlineno____doc__OperationalErrorryrwrrr__static_attributes__ __classcell__rs@r rorosW" 6" 6" 6" 6" <= K, 0))rroc^^^0mT/nU(aUR5n[U[5(a)URURUR 45 MUUR nURRnUTU'URR[U5RT55 U(aMUUU4SjnU"5$)Nc3># TR5R5H#nURT5nTUnU"S0UD6v M% g7f)Nr)dictsiteratorpop)row identifierr6rXmappingquerys r wrapped_iterator2resolve_multimodel_query..wrapped_iterator/sB;;=))+CJJ'E,#, ,sAA ) rr"rextendlhsrhsr6r& table_namer!r/Valuealias)rrXr?currr<r4rrs`` @r resolve_multimodel_queryr!sG GE yy{ d/ 0 0 LL$((DHH- . jj   ++#  uT{0056 %  rcJ^\rSrSrSrU4SjrSrSr\"\\5r Sr U=r $)ThreadSafeDatabaseMetadatai8z Metadata class to allow swapping database at run-time in a multi-threaded application. To use: class Base(Model): class Meta: model_metadata_class = ThreadSafeDatabaseMetadata cp>SUl[R"5Ul[[ U]"U0UD6 gr ) _database threadinglocal_localrvrrwrs r rw#ThreadSafeDatabaseMetadata.__init__As-oo'  ($8$I&IrcD[URSUR5$)Ndatabase)r.rr)r|s r _get_db"ThreadSafeDatabaseMetadata._get_dbGst{{J??rcJURcXlXRlgr )rrr)r|dbs r _set_db"ThreadSafeDatabaseMetadata._set_dbIs >> !N! r)rr) rrrrrrwrrpropertyrrrrs@r rr8s'J @")Hrr) TFNNNNNNF)Fr )_model_identifier)rpeeweerrrrrrr0rPrSrmobjectrorrrrr rsf&!. =A7;EJrj'TG5DK)VK)\.**r