Zil3UddlmZddlZddlmZddlZddlZddlmZddlm Z ddlm Z ddlm Z ddlm Z dd lm Z dd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlZddlZddlmZddlmZddlmZddlmZddlmZ ddlm Z eZ!de"d<edeZ#ede defZ$Gd d!e%Z&Gd"d#e&$Z'd5d%Z(d6d&Z)ed7d'Z*ed8d9d(Z*e d: d;d)Z* d: dd4Z2y)?) annotationsN)Iterable)Any)Callable)cast)Dict)List)Mapping)MutableMapping)NoReturn)Optional)overload)Sequence)Set)Tuple)Type)TypeVar)asbool) immutabledict)to_list) unique_list)inspect_getfullargspec)memoized_propertyzMapping[Any, Any] EMPTY_DICT_T)bound_C.c eZdZdfd ZxZS)_ModuleClsMetacHt||||j|yN)super __setattr___update_module_proxies)clskeyvalue __class__s T/home/portmadness/app/.venv/lib/python3.12/site-packages/alembic/util/langhelpers.pyr$z_ModuleClsMeta.__setattr__.s  C' ""3')r'strr(Callable[..., Any]returnNone)__name__ __module__ __qualname__r$ __classcell__)r)s@r*r r -s ((r+r ceZdZUdZej dZded<ed dZ ddZ ddZ e ddZ e dd Z e dd Ze dd Zy )ModuleClsProxyzCreate module level proxy functions for the methods on a given class. The functions will have a compatible signature as the methods. ctgfSr")setr+r*zModuleClsProxy.Bs  r+zaDict[Type[Any], Tuple[Set[str], List[Tuple[MutableMapping[str, Any], MutableMapping[str, Any]]]]]_setupscd|j|\}}|D]\}}|j||||yr")r:_add_proxied_attribute)r&name attr_namesmodulesglobals_locals_s r*r%z%ModuleClsProxy._update_module_proxiesDs?!kk#. G!( L Hg  & &tXw K Lr+c|j|j\}}|D] \}}||d<|D]}t||||<"yN_proxy)r:r)getattrselfr>r?r@rA attr_names r*_install_proxyzModuleClsProxy._install_proxyJsW"ll4>>: G!( ? Hg!%HX ' ? &-dI&># ? ?r+cn|j|j\}}|D]\}}d|d<|D]}||=yrC)r:r)rFs r* _remove_proxyzModuleClsProxy._remove_proxyQsN"ll4>>: G!( ( Hg!%HX ' ( Y' ( (r+ct|j|\}}|j||f|j|||yr")r:append _setup_proxy)r&r@rAr>r?s r*create_module_class_proxyz(ModuleClsProxy.create_module_class_proxyXs: "kk#. G'*+ 7J7r+cLt|D]}|j||||yr")dirr<)r&r@rAr>methnames r*rNzModuleClsProxy._setup_proxybs-C PH  & &x7J O Pr+c|jds@t||}t|r|j|||||<y|j |yy)N_) startswithrEcallable_create_method_proxyadd)r&rRr@rAr>meths r*r<z%ModuleClsProxy._add_proxied_attributelsT""3'3)D~$'$<$<h%!x((r+c t|}dfd }||d<t|dg}|rht|}|dr|dddk(r|djddx}} d|jdt |d|d } dd } | |d <nd}d} d } t j d || || |jdz} i} t| td|| td| |S)Nc>td|djd|)NzCan't invoke function 'zE', as the proxy object has not yet been established for the Alembic 'z2' class. Try placing this code inside a callable.) NameErrorr0)r=from_r&s r* _name_errorz8ModuleClsProxy._create_method_proxy.._name_errors%  '   r+r^_legacy_translationsrrGz *args, **kwzargs, kw = _translate(z, z , args, kw)c i}g}|D]=\}}||vs tjd|d|d|d|j|||<?|j|t |}|dr|ddt |d } n|d} | D](} | |vs |j |jd*|j|||fS#t$rtd| zwxYw)Nz Argument z is now named z for method z().rz(missing required positional argument: %s) warningswarnpopupdatelistlenrM IndexError TypeErrorextend) fn_namespec translationsargskw return_kw return_argsoldnamenewnamepos_onlyargs r* translatez6ModuleClsProxy._create_method_proxy..translates  (4=$GW"} 297GM.0VVG_ '* =  $Dz7#Aw#d1g,7H#AwH#C)+'..txx{;""4("I-- *"+ J"%!&#s  CC _translatea def %(name)s(%(args)s): %(doc)r %(translate)s try: p = _proxy except NameError as ne: _name_error('%(name)s', ne) return _proxy.%(name)s(%(apply_kw)s) e )r=rvrnapply_kwdoczDict[str, Any]r-)r=r,r] Exceptionr.r ) rkr,rlrrmrrnrrorr.r) rErrdr0tupletextwrapdedent__doc__execr)r&r=r@rAfnr^rmrl outer_args inner_args translate_strrv func_textlcls` r*rWz#ModuleClsProxy._create_method_proxy}s5S$  #.r#92> )"-DAw471:/Q A&3 3J d M  . .$' .7: .BE .KN . .B&/H\ "&J&JMOO *"&zz   ()+ Y-x8#>(#d)44r+N)r=r,r.r/r.r/)r@MutableMapping[str, Any]rArr.r/)r@rrArr>Set[str]r.r/) rRr,r@rrArr>rr.r/)r=r,r@rrArr.r-)r0r1r2r collections defaultdictr:__annotations__ classmethodr%rIrKrOrNr<rWr8r+r*r5r53s=  34  5LL ?(8*8*8  88P*P*P P  PP))+)* )  )  )) ^5^5+^5* ^5  ^5^5r+r5) metaclasscdfd }|S)Nc|_|Sr")r_)rrms r*decoratez$_with_legacy_names..decorates". r+rrr.rr8)rmrs` r*_with_legacy_namesrs Or+cDtjjddS)Ni)uuiduuid4hexr8r+r*rev_idrs ::<  CD !!r+cyr"r8xdefaults r*to_tuplersCFr+cyr"r8rs r*rrs:=r+cyr"r8rs r*rrsr+cl||St|tr|fSt|tr t|S|fSr") isinstancer,rr|rs r*rrs9 y As t Ax Qxt r+c*tt|Sr")r|r)tups r* dedupe_tuplers S! ""r+cVeZdZdZej Z ej Zy)PriorityDispatchResultzyindicate an action after running a function within a :class:`.PriorityDispatcher` .. versionadded:: 1.18.0 N)r0r1r2renumautoCONTINUESTOPr8r+r*rr s-tyy{H 499;DCr+rc eZdZdZdZ dZ dZy)DispatchPriorityzIndicate which of three sub-collections a function inside a :class:`.PriorityDispatcher` should be placed. .. versionadded:: 1.18.0 2 N)r0r1r2rFIRSTMEDIUMLASTr8r+r*rrs! EM FC D9r+rcDeZdZd dZddd d dZd d dZd dZy) Dispatcherci|_yr") _registryrGs r*__init__zDispatcher.__init__1s 57r+rF) qualifierreplacec dfd }|S)Nclfjvrstdd|jf<|S)Nz)Can not set dispatch function for object zE: key already exists. To replace existing function, use replace=True.)r ValueError)rrrrGtargets r*rz)Dispatcher.dispatch_for..decorate;sO "dnn4W ?j!;; 35DNNFI. /Ir+rr8)rGrrrrs```` r* dispatch_forzDispatcher.dispatch_for4s  r+c*t|tr|g}n2t|tr |j}nt|j}|dk7r|dg}ndg}|D].}|D]'}||f|jvs|j||fccS0t d|z)Nrz#no dispatch function for object: %s)rr,type__mro__rr)rGobjrtargets qualifiersspclss r*dispatchzDispatcher.dispatchGs c3 &)UG T "kkG3i''G  !#Y/J#J JE' > 9%7>>5)*<== > J BSHI Ir+cdt}|jj|j|SzHReturn a copy of this dispatcher that is independently writable.)rrrerGds r*branchzDispatcher.branch[s& L 4>>*r+Nr)rrrr,rboolr.Callable[[_C], _C])r)rrrr,r.r)r.r)r0r1r2rrrrr8r+r*rr0sE8#      &J(r+rcxeZdZdZd dZej ddd d dZdd d dZdd Z dd Z y)PriorityDispatcherzregisters lists of functions at multiple levels of priorty and provides a target to invoke them in priority order. .. versionadded:: 1.18.0 - PriorityDispatcher replaces the job of Dispatcher(uselist=True) c@tjt|_yr")rrrfrrs r*rzPriorityDispatcher.__init__ms5@5L5L 6 r+rN)priorityrsubgroupc$dfd }|S)a-return a decorator callable that registers a function at a given priority, with a given qualifier, to fire off for a given subgroup. It's important this remains as a decorator to support third party plugins who are populating the dispatcher using that style. cNjfj|f|Sr")rrM)rrrrGrrs r*rz1PriorityDispatcher.dispatch_for..decorates/ NNFIx8 9 @ @X Ir+rr8)rGrrrrrs````` r*rzPriorityDispatcher.dispatch_forrs"   r+)rc6|dk7r|dgndgdfd }|S)z6Provide a callable for the given target and qualifier.rci}tD]n}D]g} jj ||fdD]C\}}|j|tjtj ur7||i|}|||<Eipy)Nr8)rrgetrrr) ruroresults_by_subgrouprrrrresultrrGrs r*goz'PriorityDispatcher.dispatch..gosEG , ?!+ ?I(,(:(:H5r) ? H033 (*@*I*I 6::; %!#SB8>+H5 ? ? ?r+)rurrorr.rr8)rGrrrrs`` @r*rzPriorityDispatcher.dispatchs*  !#Y/J#J ?$ r+c<t}|j||Sr)r populate_withrs r*rzPriorityDispatcher.branchs   r+c|jD]/}|j|}|j|j|1y)zPopulate this PriorityDispatcher with the contents of another one. Additive, does not remove existing contents. N)rrj)rGotherknew_lists r*rz PriorityDispatcher.populate_withs<  /Aq)H NN1  $ $X . /r+r) rr,rrrr,rz str | Noner.r)rr,rr,r.zCallable[..., None])r.r)rrr.r/) r0r1r2rrrrrrrrr8r+r*rrds~ &6%<%<"# #      409), </r+rc|J|Sr"r8)r(s r*not_noners    Lr+)rmrr.r)r.r,)rrrTuple[Any, ...]r.r).)rr/r Optional[_T]r.rr")rrrOptional[Tuple[Any, ...]]r.r)rrrrr.r)rTuple[str, ...]r.r)r(rr.r)3 __future__rrcollections.abcrrr}typingrrrrr r r r r rrrrrrrrbsqlalchemy.utilrrrrcompatrrrrrrrr r5rrrrEnumrIntEnumrrrrr8r+r*rsh"$ ! ,:.6* !. / T T#s(+,(T( i5~i5X" F F = = 15 .  26   .  #DTYYD(:t||:$11hT/T/nr+