ɯei6pdZddlZddlmZddlmZddlmZmZm Z m Z m Z m Z m Z erddlmZGddZGd d e ZGd d eZeed dddeeddddeededdeededdeeddddiZeZGd d!eZGd"d#Zd#gZy)$z?Module houses ``Parameter`` class - base class for all configs.N) defaultdict)IntEnum) TYPE_CHECKINGAnyCallable DefaultDict NamedTupleOptionalcast)EnvironmentVariableceZdZUdZeded<eeded<eed< ddeddeedd eefd Zdd e d efd Z y)DeprecationDescriptora Describe deprecated parameter. Parameters ---------- parameter : type[Parameter] Deprecated parameter. new_parameter : type[Parameter], optional If there's a replacement parameter for the deprecated one, specify it here. when_removed : str, optional If known, the exact release when the deprecated parameter is planned to be removed. Parameter _parameter_new_parameter _when_removedN parameter new_parameter when_removedcB||_||_|d|_y||_y)Nza future)rrr)selfrrrs h/var/www/html/glpi_dashboard/venv/lib/python3.12/site-packages/snowflake/snowpark/modin/config/pubsub.py__init__zDeprecationDescriptor.__init__/s' $++7+?Z\use_envvar_namesreturnc6|r td|jjn|jj}d|d|jd}|j A|r td|j jn|j j}|d|dz }|S)a Generate a message to be used in a warning raised when using the deprecated parameter. Parameters ---------- use_envvar_names : bool, default: False Whether to use environment variable names in the warning. If ``True``, both ``self._parameter`` and ``self._new_parameter`` have to be a type of ``EnvironmentVariable``. Returns ------- str r 'z'' is deprecated and will be removed in z version.z Use 'z ' instead.)r rvarname__name__rr)rrnamemsgnew_names rdeprecation_messagez)DeprecationDescriptor.deprecation_message9s   & 8 @ @)) $>t?Q?Q>RR[\    *$*D,?,?@HH((11  VH:Z0 0C r)NNF) r __module__ __qualname____doc__type__annotations__r strrboolr$rrrrs} [!!T+.// 6:&* R $R [ 12Rsm RDSrrc^eZdZUdZeegefed<eegefed<eegefed<eed<y)TypeDescriptora Class for config data manipulating of exact type. Parameters ---------- decode : callable Callable to decode config value from the raw data. normalize : callable Callable to bring different config value variations to the single form. verify : callable Callable to check that config value satisfies given config type requirements. help : str Class description string. decode normalizeverifyhelpN) r r&r'r(rr+objectr*r,r-rrr/r/WsB" cUF] ##&()) fXt^ $$ Irr/ceZdZdZy)ExactStrzDClass to be used in type params where no transformations are needed.N)r r&r'r(r-rrr6r6osNrr6c>|jjSN)striptitlevalues rr=usU[[]002rcPt|jjSr8)r+r9r:r;s rr=r=vsE 0 0 2 8 8 :rcyNTr-r;s rr=r=wrza case-insensitive string)r0r1r2r3c|Sr8r-r;s rr=r={sUrc|Sr8r-r;s rr=r=|srcyr@r-r;s rr=r=}rArza stringcB|jjdvS)N>1yestrue)r9lowerr;s rr=r=sU[[]0026JJrct|txs2t|txr |jj dvS)N>0rFnorGrHfalse) isinstancer,r+r9rIr;s rr=r=s=Zt4 uc " R ##%)QQrz^a boolean flag (any of 'true', 'yes' or '1' in case insensitive manner is considered positive)c4t|jSr8)intr9r;s rr=r=sS/rct|txs0t|txr|jj Sr8)rNrPr+r9isdigitr;s rr=r=s4Zs3@ uc " >u{{}'<'<'>rzan integer valuec |jdDcic]R}|jddDcgc]}|jc}\}}||jr t|n|Tc}}}}Scc}wcc}}}}wN,=)maxsplit)splitr9rRrPr< key_valuekeyvalvs rr=r=so"[[-  1:q1QRAaggiRS S[[]S 3C S sA9 A4&A9 4A9 c 8t|tr|St|jdDcic]R}|jddDcgc]}|j c}\}}||j r t |n|Tc}}}}Scc}wcc}}}}wrT)rNdictr+rYr9rRrPrZs rr=r=s%&  "%U!1!1#!65>__SST_5U!V!'')!VHCSXC7 "WsB B#&B B ct|txs3t|txr!td|j dDS)Nc3^K|]%}|jddt|dz fv'yw)rVrWN)findlen).0r[s r z..s4s#BI0B+CCs+-rU)rNr`r+allrYr;s rr=r=sBZt4 uc " !&S!1rzba sequence of KEY=VALUE values separated by comma (Example: 'KEY1=VALUE1,KEY2=VALUE2,KEY3=VALUE3')ceZdZdZdZdZdZy) ValueSourcezEClass that describes the method of getting the value for a parameter.rrWN)r r&r'r(DEFAULT SET_BY_USERGOT_FROM_CFG_SOURCEr-rrrjrjsOGKrrjceZdZUdZdZeeedfed<eZ dZ ee ed<dZ dZ eeed<eZe ed<gZeed <eeZee efed <dZeeed <ed efd Zed efdZd!de dedeffd Zeded dfdZed e fdZ ed efdZ!ed e fdZ"ede d dfdZ#ede ded dfdZ$ede d e fdZ%ede d dfdZ&ede d e fd Z'xZ(S)"ra Base class describing interface for configuration entities. Attributes ---------- choices : Optional[Sequence[str]] Array with possible options of ``Parameter`` values. type : str String that denotes ``Parameter`` type. default : Optional[Any] ``Parameter`` default value. is_abstract : bool, default: True Whether or not ``Parameter`` is abstract. _value_source : Optional[ValueSource] Source of the ``Parameter`` value, should be set by ``ValueSource``. _deprecation_descriptor : Optional[DeprecationDescriptor] Indicate whether this parameter is deprecated. N.choicesdefaultT _value_source_value_subs_once_deprecation_descriptorrct)au Read the value from config storage. Returns ------- str Config raw value. Raises ------ KeyError If value is absent. Notes ----- Config storage can be config file or environment variable or whatever. Method should be implemented in the child class. NotImplementedErrorclss r_get_raw_from_configzParameter._get_raw_from_configs ("##rct)z Generate user-presentable help for the option. Returns ------- str Notes ----- Method should be implemented in the child class. rxrzs rget_helpzParameter.get_helps "##rr)abstractkwc |tvs Jd|||_||_t|_g|_t t|_t|(di|y)a Initialize subclass. Parameters ---------- type : Any Type of the config. abstract : bool, default: False Whether config is abstract. **kw : dict Optional arguments for config initialization. zUnsupported variable type: Nr-) _TYPE_PARAMSr) is_abstract_UNSETrsrtrlistrusuper__init_subclass__)r{r)rr __class__s rrzParameter.__init_subclass__sX|#I'B4&%II#"  %  !'B'rcallbackcJ|jj|||y)z Add `callback` to the `_subs` list and then execute it. Parameters ---------- callback : callable Callable to execute. N)rtappend)r{rs r subscribezParameter.subscribes " rc|jS)z_ Get default value of the config. Returns ------- Any )rqrzs r _get_defaultzParameter._get_default"s{{rcx|j|j|jJd|jS)zf Get value source of the config. Returns ------- ValueSource z1_value_source must be initialized by now in get())rrgetrzs rget_value_sourcezParameter.get_value_source-sA    $ GGI    ) ? > ? )   rcT|j2tj|jjt|j t ur |j}t|jj|std|t|jj||_tj|_|j S|j S#t $r8|j#|_tj$|_Y|j SwxYw)z Get config value. Returns ------- Any Decoded and verified config value. zUnsupported raw value: )rvwarningswarnr$ FutureWarningrsrr|rr)r2 ValueErrorr0rjrnrrKeyErrorrrl)r{raws rrz Parameter.get>s  & & 2 MM++??A=  ::  D..0 $CHH-44S9$'>se%DEE)#((3::3? $/$C$C!zzszz 8 --/ $/$7$7! zz 8sC&&3D'&D'r<c|j2tj|jjt|j |j |tj|_ y)z Set config value. Parameters ---------- value : Any Config value to set. N) rvrrr$r_check_callbacks_put_nocallbackrjrmrr)r{r<s rputz Parameter.putZsY  & & 2 MM++??A=  S0078'33ronvaluect|jj|}||jk(r ||y|j|j |y)a Execute `callback` if config value matches `onvalue` value. Otherwise accumulate callbacks associated with the given `onvalue` in the `_once` container. Parameters ---------- onvalue : Any Config value to set. callback : callable Callable that should be executed if config value matches `onvalue`. N)rr)r1rrur)r{rrs roncezParameter.onceksIsxx(227; cggi  SM IIg  % %h /rct|jj|std|t|jj |}|j |c}|_|S)z Set config value without executing callbacks. Parameters ---------- value : Any Config value to set. Returns ------- Any Replaced (old) config value. zUnsupported value: )rr)r2rr1rrs)r{r<oldvalues rrzParameter._put_nocallbacks`CHH%,,U325':; ;SXX&007"wwy%#*rrc||jk(ry|jD] }|| |jj|jdD] }|| y)z Execute all needed callbacks if config value was changed. Parameters ---------- oldvalue : Any Previous (old) config value. Nr-)rrtrupop)r{rrs rrzParameter._check_callbackssZ swwy   H SM  cggi4 H SM rchoicec |jxt|jj|st d|t|jj |}||jvr|xj|fz c_|St d)a Add a new choice for the parameter. Parameters ---------- choice : Any New choice to add to the available choices. Returns ------- Any Added choice normalized according to the parameter type. zUnsupported choice value: z8Cannot add a choice to a parameter where choices is None)rprr)r2rr1 TypeError)r{rs r add_optionzParameter.add_options~ ;; ")008 #=fX!FGG!#((+55f=FS[[( y( MRSSrr%))r r&r'r(rpr tupler+r*r)rqrrrrrjrrsrtrrrurrvr classmethodr|r~r,r`rrrrrrrrrrr __classcell__)rs@rrrs(*.GXeCHo &- D!GXc]!K+/M8K(/FCE4$/$5E;sDy !5?CX&;<C$S$$* $ $ $(S(D((*  d  S!!! C64444 030(0t00(CC( TTTTrr)r(r collectionsrenumrtypingrrrrr r r 'snowflake.snowpark.modin.config.envvarsr rr/r+r6r,rPr`rr4rrjr__all__r-rrrs$F#XXXK77tZ0OsO 2:! (    n"%!    .J n /@    .   r/ =7 v '@T@TF -r