biUddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z ddlZddlZddlmZmZddlmZddlmZdd lmZmZmZe rdd l mZmZdd lmZe d Zd e d<dZ!GddZ"Gdde"Z#d*dZ$d+d,dZ%d-dZ&Gdde"Z'Gdde"Z(Gdde(Z)Gdde"Z*Gdd e"Z+Gd!d"Z,Gd#d$e"Z-d%Z.Gd&d'e(Z/Gd(d)e"Z0y).) annotationsN) defaultdict) Generator) TYPE_CHECKINGLiteral)Taskconvert_legacy_graph)_tokenize_deterministic)Key) ensure_dictfuncnameimport_required)Any TypeAliasHighLevelGraph)logicalsimplified-logical tuned-logicalphysicalsimplified-physicalfusedrOptimizerStagec~ddlm}t|tr|St |drt||s |j S|S)NrDelayedexpr) dask.delayedr isinstanceExprhasattrr)ors E/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/dask/_expr.py_unpack_collectionsr$$s5$!Tq&*Q"8vv c:eZdZUgZded<iZded<dZded<ded <d ed <d d dZdZdZ dZ dZ dZ dZ dZdAdZdZdBdCdZ dD dEdZdZdZdZdZedZdZdFd ZdGd!Zd"Zd#ZdHd$ZdId%ZdJd&Z dKd'Z!dLdMd(Z"dNd)Z#dNd*Z$d+Z%d,Z&dOd-Z'dNd.Z(d/Z)e*jVdPd0Z,e-d1Z.e*jVdPd2Z/e-d3Z0e1dQd4Z2d5Z3d6Z4e-d7Z5dNd8Z6d9Z7dRd:Z8d;Z9 dSd<Z:dTd=Z;dUd>Zy )Wr z list[str] _parameterszdict[str, Any] _defaultsTbool_pickle_functools_cachelistoperands str | None _determ_tokenNr.ct|}|jt|dD]#} |j|j |%|rJ|tj|}||_ |Dcgc] }t|c}|_ |j|S#t $r!|j|j |YwxYwcc}wN) r+r'lenappendpopKeyErrorr(object__new__r.r$r,_name)clsr.argskwargsr, parameterinstr"s r#r7z Expr.__new__:s:X9 :I : 9 56 : !6!z~~c"*9ABA,Q/B    : i 89 : Cs B3C'CCcyr1selfs r# _tune_downzExpr._tune_downKr%cyr1r?)rAparents r#_tune_upz Expr._tune_upNrCr%c|Sr1r?r@s r#finalize_computezExpr.finalize_computeQ r%c t|j|jDcgc]\}}|dt|c}}Scc}}w)N=)zipr'r,repr)rAparamops r#_operands_for_reprzExpr._operands_for_reprTsC36t7G7G3W &/eRugQtBxj !   sAcvdj|j}t|jd|dS)N, ())joinrPtype__name__)rAss r#__str__z Expr.__str__Ys7 IId--/ 0t*%%&as!,,r%ct|Sr1)strr@s r#__repr__z Expr.__repr__]s 4yr%c> |j|}|j|}t |t |k7r&|r|d|dt |z }|S|t |z }|S#ttf$r.|t |jkr|j|nd}d}Y{wxYw)Nz--no-default-- rK)r'r( IndexErrorr5r2rM)rAirOheaderrNdefaults r# _tree_repr_argument_constructionz%Expr._tree_repr_argument_construction`s '$$Q'EnnU+G 8tG} $AeWAd2hZ00 $r(" H% '+,s43C3C/D+DD$$Q'"E&G 'sA:BBc$d|zt|zS)Nr_)rMrAindent recursives r#_tree_repr_lineszExpr._tree_repr_linesosV|d4j((r%c\tjj|jSr1)oslineseprUrir@s r# tree_reprzExpr.tree_reprrszzt44677r%c^ddlm}ddlm}t ||s t d||||S)Nr)r )analyzez:analyze is only supported for dask.dataframe.Expr objects.)filenameformat)dask.dataframe.dask_expr._exprr $dask.dataframe.dask_expr.diagnosticsror TypeError)rArprqDFExprros r#roz Expr.analyzeus3A@$'L thv>>r%c"ddlm}||||S)Nr)explain)rsrw)rAstagerqrws r#rwz Expr.explains AtUF++r%cD|jD] }t|yr1)riprint)rAlines r#pprintz Expr.pprints!))+ D $K r%c,t|jSr1)hashr8r@s r#__hash__z Expr.__hash__sDJJr%cz|js$tt|g|j|_|jSr1)r.r rVr,r@s r#__dask_tokenize__zExpr.__dask_tokenize__s3!! "9d!Tdmm!TD !!!r%cjt|jDcgc]}|j|fc}Scc}w)zThe keys for this expression This is used to determine the keys of the output collection when this expression is computed. Returns ------- keys: list The keys for this expression )range npartitionsr8rAras r# __dask_keys__zExpr.__dask_keys__s+*/t/?/?)@AAQAAAs0cr|^}}}}||d|i}|jD]\}}||j|<|S)Nr.)items__dict__)r:typr,tokencacher=kvs r# _reconstructzExpr._reconstructsK'+$huH2E2KKM !DAq DMM!  ! r%ctjjddrtdt |di}t |j rdt |j jD]>\}}t|tjs!||j vs0t||||<@tjt |g|j|j|fS)Nzdask-expr-no-serializeFzSerializing a z object)daskconfigget RuntimeErrorrVr*rrr functoolscached_propertygetattrr rr,deterministic_token)rArrrs r# __reduce__zExpr.__reduce__s ;;??3U ;T |7CD D : - -T ++113 01a!:!:;T]]@R&tQ/E!H 0  J# ]]#   $ $#   #   r%c4|i}|jsyg}|jD]d}|j|vr|j||j0|j|j|dz|d||j<ft |S)zYDepth of the expression tree Returns ------- depth: int ) dependenciesr8r3_depthmax)rArresultrs r#rz Expr._depths =E  "F))+ 3::&MM% "34MM$++e"4q"89(.r E$**%  3 v; r%c|dvrtj|||y t|j}tj |d}|||j |<y#t $r$tt|jd|wxYw)N)r,r.r,z object has no attribute ) r6 __setattr__rVr'__getattribute__index ValueErrorAttributeErrorrW)rAnamevalueparamsr,s r#rzExpr.__setattr__s 0 0   tT5 1  $Z++F..tZ@H+0HV\\$' (  :&&''@G  s ?A-B cd|jt|jj|Sr1)r,rVr'r)rAkeys r#operandz Expr.operands(}}T$Z3399#>??r%cb|jDcgc]}t|ts|c}Scc}wr1)r,rr )rArs r#rzExpr.dependenciess#'+}}RG 7D8QRRRs,,c2tdt|d)aThe task for the i'th partition Parameters ---------- index: The index of the partition of this dataframe Examples -------- >>> class Add(Expr): ... def _task(self, i): ... return Task( ... self.__dask_keys__()[i], ... operator.add, ... TaskRef((self.left._name, i)), ... TaskRef((self.right._name, i)) ... ) Returns ------- task: The Dask task to compute this partition See Also -------- Expr._layer zcExpressions should define either _layer (full dictionary) or _task (single task). This expression z defines neither)NotImplementedErrorrV)rArrs r#_taskz Expr._tasks(8" 004T |;K M  r%ct|jDcic]-}|j|f|j|j|f|/c}Scc}w)a@The graph layer added by this expression. Simple expressions that apply one task per partition can choose to only implement `Expr._task` instead. Examples -------- >>> class Add(Expr): ... def _layer(self): ... return { ... name: Task( ... name, ... operator.add, ... TaskRef((self.left._name, i)), ... TaskRef((self.right._name, i)) ... ) ... for i, name in enumerate(self.__dask_keys__()) ... } Returns ------- layer: dict The Dask task graph added by this expression See Also -------- Expr._task Expr.__dask_graph__ )rrr8rrs r#_layerz Expr._layersPB4++, ZZOTZZQ; ;   s2A c|j|vr||jS|}d|d}d|d} d}t||}||}t|ts|S|j|jk7r|}F|j D]P}t|||}||}t|ts|cS||us2|j|jk7sL|}d}n|rg} d} |j D]c} t| tr>| j ||} | || j<| j| jk7rd} n| } | j| e| rt|| }4 |S)aRewrite an expression This leverages the ``._{kind}_down`` and ``._{kind}_up`` methods defined on each class Returns ------- expr: output expression changed: whether or not any change occurred __down_upTFkind rewritten) r8rrr rr,rewriter3rV) rArrr down_nameup_name _continueoutchild new_operandschangedrnews r#rz Expr.rewrite+s :: "TZZ( (vUO dV3-I+'$ *,C{c4( yyDJJ&**, -geW-d3;C!#t,Jd?syyDJJ'>D $I LG== )gt,!//ty/IC/2Igmm,yyGMM1"&!C##C( )!tDz<0 r%c|j|vr||jS|} |j}||}t|ts|S|j|jk7r|}|j D]N}|j ||}||}t|ts|cS||us2|j|jk7sL|}ng}d}|j D]}t|tro||jjtj||j||} | ||j<| j|jk7rd}n|} |j| |rt||} |S)aSimplify an expression This leverages the ``._simplify_down`` and ``._simplify_up`` methods defined on each class Parameters ---------- dependents: defaultdict[list] The dependents for every node. simplified: dict Cache of simplified expressions for these dependents. Returns ------- expr: output expression TF dependents simplified) r8_simplify_downrr r _simplify_upr,r3weakrefref simplify_oncerV) rArrrrrrrrrs r#rzExpr.simplify_onceos~( :: #djj) )%%'C{c4( yyDJJ&**, ((z:;C!#t,Jd?syyDJJ'>D LG== )gt,w}}-44W[[5FG!//#-*0C14Jw}}-yyGMM1"&!C##C( )!tDz<0  r%c&|rdnd}t||S)Nrroptimize_until)rAfuserxs r#optimizez Expr.optimizes+/5JdE**r%c|Sr1r?r@s r#rz Expr.fuserIr%c |}t} t|}|j|i}|j|jk(r |S|j|vrt d|d|d|j |j|}x)NrzOptimizer does not converge. z simplified to zf which was already seen. Please report this issue on the dask issue tracker with a minimal reproducer.)setcollect_dependentsrr8radd)rArseenrrs r#simplifyz Expr.simplifysu+D1J$$ r$JCyyDJJ& yyD "3D8?3'Rdd HHSYY Dr%cyr1r?r@s r#rzExpr._simplify_downr%cyr1r?)rArErs r#rzExpr._simplify_uprr%c ||jS#t$rYnwxYw|}|j}||}t|ts|Sg}d}|j D]R}t|tr-|j |}|j|jk7rd}n|}|j|T|rt||}|j|j|S)NFT) r8r5_lowerrr r, lower_oncer3rV setdefault)rAloweredrrrrrrs r#rzExpr.lower_onces 4::& &   kkm ;C#t$J || %G'4(((199 -"G    $ % $s)\*C!!$**c22s  cl|}i} |j|}|j|jk(r |S|}0)alLower an expression completely This calls the ``lower_once`` method in a loop until nothing changes. This function does not apply any other optimizations (like ``simplify``). Returns ------- expr: output expression See Also -------- Expr.lower_once Expr._lower )rr8)rArrrs r#lower_completelyzExpr.lower_completelysC$//'*CyyDJJ& D r%cyr1r?r@s r#rz Expr._lowerrr%cFtt|jSr1)r rVlowerr@s r# _funcnamezExpr._funcnamesT #))++r%c\|js|j|_|jSr1)r.rr@s r#rzExpr.deterministic_tokens*!!"&!7!7!9D !!!r%c:|jdz|jzS)N-)rrr@s r#r8z Expr._name s~~#d&>&>>>r%ctr1)rr@s r#_metaz Expr._meta$s !##r%ctSr1)_AnnotationsTombstone)r9s r#_annotations_tombstonezExpr._annotations_tombstone(s $&&r%ciSr1r?r@s r#__dask_annotations__zExpr.__dask_annotations__,s r%cR|g}t}g}|r|j}|j|vr!|j|j|j |j |j D]}|j ||rtj|S)a/Traverse expression tree, collect layers Subclasses generally do not want to override this method unless custom logic is required to treat (e.g. ignore) specific operands during graph generation. See also -------- Expr._layer Expr._task ) rr4r8rr3rrtoolzmerge)rAstackrlayersrrs r#__dask_graph__zExpr.__dask_graph__/su99;DzzT! HHTZZ MM$++- (,,. & W% &{{6""r%c"|jSr1)rr@s r#rz Expr.daskKs""$$r%c:|j||tS)aSubstitute a specific term within the expression Note that replacing non-`Expr` terms may produce unexpected results, and is not recommended. Substituting boolean values is not allowed. Parameters ---------- old: Old term to find and replace. new: New term to replace instances of `old` with. Examples -------- >>> (df + 10).substitute(10, 20) # doctest: +SKIP df + 20 )_seen) _substituter)rAoldrs r# substitutezExpr.substituteOs&S66r%c |j|vr|St|trd}|j|jk(r|Sd}t|tr t dg}d}|j D]:}t|tr@|j |||}|j|jk7rd}|j|Tdt|jvr~t|trntd|Dr\g}|D]C} |j| j ||||dj| jk7sBd}E|j||r?t|ts/t|t|r||k(r|j|d}*|j|=|rt||S|j|j|S)NFTz)Arguments to `substitute` cannot be bool.Fusedc3<K|]}t|tywr1)rr .0rOs r# z#Expr._substitute..|s? 2t,?r) r8rr r)rtr,rr3rVrWr+allr) rArrrsubstitute_literal new_exprsupdatervalrOs r#rzExpr._substituteds :: K c4 !& zzSYY& !% #t$ KLL }} *G'4())#sE:==CII-!F  %4:...w-?w?? !&BJJr~~c3>?2w}}0!%&  %""7D1wS 2sN  %  )= *@ 4:y) ) IIdjj ! r%c,|s|Sd}g}t|jD]c\}}|t|jkr5|j||vr$|j ||j|d}S|j |e|rt ||S|S)zSubstitute specific `Expr` parameters Parameters ---------- substitutions: Mapping of parameter keys to new values. Keys that are not found in ``self._parameters`` will be ignored. FT) enumerater,r2r'r3rV)rA substitutionsrrrars r#substitute_parameterszExpr.substitute_parameterssK #DMM2 -JAw3t''((T-=-=a-@M-Q##M$2B2B12E$FG##G,  - 4:|, , r%c"|jS)z4Operands to include in the node label by `visualize`rr@s r#_node_label_argszExpr._node_label_argss  ""r%c ddlm}m}tdd}|xsi}|xsi}|xsi}||d<d|d<d|d <|j ||j ||| } |g} t } i} | r| j} | j| vr!| j| jt | j| | <| jD]}| j|| ri}| D]} || }i}| jDcgc]1}t|trtt!|n t#|3}}tt!| }|r|r|d d j%|d n|}|||}|j'dt#||j'dd| j(|fi|| j+D].\} }|| }|D]}||}| j-||0| Scc}w)Nr)labelrgraphvizaJDrawing dask graphs with the graphviz visualization engine requires the `graphviz` python library and the `graphviz` system library. Please either conda or pip install as follows: conda install python-graphviz # either conda install python -m pip install graphviz # or pip install and follow installation instructionsrankdirboxshape helveticafontname) graph_attr node_attr edge_attrrSrRrT)rrfontsize20)dask.dotrrrrDigraphrr4r8rrr3rrr r rVr[rUrnoderedge)rArrrrr;rrrgrrrrdepr expr_nameattrsdeps_label node_labeldep_names r# _to_graphvizzExpr._to_graphvizs: )"  h  %2 O O ' 9" ' + *&!   !   u 99;DzzT! HHTZZ !$T%6%6%8!9L ((* " S! "  'DT IE  002(2#t'<c##c(JDd4j)F;?F81TYYt_$5Q7VvU3J   Wc*o 6   Z . AFF9 & &! '$',,. ,JD$T I ,9x+ , , 's6Hc Jddlm}|jdi|}|||||S)a Visualize the expression graph. Requires ``graphviz`` to be installed. Parameters ---------- filename : str or None, optional The name of the file to write to disk. If the provided `filename` doesn't include an extension, '.png' will be used by default. If `filename` is None, no file will be written, and the graph is rendered in the Jupyter notebook only. format : {'png', 'pdf', 'dot', 'svg', 'jpeg', 'jpg'}, optional Format in which to write output file. Default is 'svg'. **kwargs Additional keyword arguments to forward to ``to_graphviz``. r)graphviz_to_filer?)rr*r()rArprqr;r*r s r# visualizezExpr.visualizes-" . D   ' 'Hf-r%c#K|g}t}|rh|j}|j|vr!|j|j|j D]}|j |||rgyyw)zIterate through all expressions in the tree Returns ------- nodes Generator of Expr instances in the graph. Ordering is a depth-first search of the expression tree N)rr4r8rrr3)rArrrr!s r#walkz Expr.walkssu99;DzzT! HHTZZ ((* " S! "Js A6A;9A;cttrtdDsttsJdfd|j DS)aZSearch the expression graph for a specific operation type Parameters ---------- operation The operation type to search for. Returns ------- nodes Generator of `operation` instances. Ordering corresponds to a depth-first search of the expression graph. c3<K|]}t|tywr1) issubclassr )res r#rz'Expr.find_operations..=s;AJq$';rz#`operation` must be`Expr` subclass)c3<K|]}t|s|ywr1)r)rr operations r#rz'Expr.find_operations..@sL 40KLs)rtuplerr0r r-)rAr3s `r#find_operationszExpr.find_operations-sO y% (;;;)T* 1 1  1 +MLLr%c* tj||S#t$rq}|jdrt d|dt |j }||vr%|j|}|j|cYd}~St|dd}~wwxYw)Nrz Failed to generate metadata for z=. This operation may not be supported by the current backend.zO This often means that you are attempting to use an unsupported API function..) r6rr startswithrrVr'rr,)rArerrr'idxs r# __getattr__zExpr.__getattr__Bs **45 5 ~~g&#6tf=RRt*00Kk!!'',}}S)) %!" # s! BAB 9B?B  BrT)NN)rpr-rqr-returnNone)rN)rxrrqr-r<r=r1)rr[rrr<r=)rr rintr<rr<dict)rr[)rrrr@)F)rr)r<r )r<r )rr@)r<r[)r<r)r r@r<r )BTNNN)z dask-expr.svgN)r<Generator[Expr])r3ztype | tuple[type]r<rB)?rW __module__ __qualname__r'__annotations__r(r*r7rBrFrHrPrYr\rdrirmrorwr|rrr staticmethodrrrrrrrrrrrrrrrrrrrrrpropertyrr8r classmethodrrrrrrr rr(r+r-r5r:r?r%r#r r 0sK "I~"$(T(N*." - )8?EI,#,7A, , " B * @ S B" HBHDL+ " 3D6,,""??$$''#8%%7*3j0#  IV.,M*r%r c4eZdZUdZded<ddfd ZxZS) SingletonExpraA singleton Expr class This is used to treat the subclassed expression as a singleton. Singletons are deduplicated by expr._name which is typically based on the dask.tokenize output. This is a crucial performance optimization for expressions that walk through an optimizer and are recreated repeatedly but isn't safe for objects that cannot be reliably or quickly tokenized. z/weakref.WeakValueDictionary[str, SingletonExpr] _instancesNr/c&t|dstj|_t ||g|d|i|}|j }||jvr,|jtjk(r|j|S||j|<|S)NrKr.) r!rWeakValueDictionaryrKsuperr7r8__init__r6)r9r.r:r;r=r8 __class__s r#r7zSingletonExpr.__new__kssL)$88:CNwsQTQQ&Q  CNN "s||v'F>>%( ( $u r%)rWrCrD__doc__rEr7 __classcell__rPs@r#rJrJ]s @?*.  r%rJcjtt}|g}t}|r|j}|j|vr!|j |j|j D]D}|j|||jjtj|F|r|Sr1) rr+rr4r8rrr3rr)rrrrrr!s r#rrwsT"J FE 5D yy{ ::   $$& C&C#~##C((r%cx|js#tjj|_|jSr1)r.uuiduuid4hexr@s r#rzHLGExpr.deterministic_token1s+!!!%!1!1D !!!r%c0|j}t|Sr1)rxr )rArZs r#rzHLGExpr._layer7s!!3r%Tr<zdict[str, dict[Key, object]]r<rr?)rWrCrDr'r(rGrfrFrtrHrrrrrxrrr?r%r#r_r_sK $! I##    D  )  ))""  r%r_c eZdZy) _HLGExprGroupNrWrCrDr?r%r#rr<s r%rcleZdZdZdZd dZdZdZejd dZ dZ e Z d dZ dd Zy )_HLGExprSequencec |j|Sr1r,rAothers r# __getitem__z_HLGExprSequence.__getitem__D}}U##r%cRd|jdd|jdgS)Nzname=rzdsk=rZrer@s r#rPz#_HLGExprSequence._operands_for_reprGs4DLL(+ ,4<<&) *  r%c"|jSr1)rPrfs r#riz!_HLGExprSequence._tree_repr_linesMs&&((r%cht|jDcgc]}|jc}Scc}wr1)rr,rH)rArOs r#rHz!_HLGExprSequence.finalize_computePs($--!PB""5"5"7!PQQ!Ps/c 0t|jdk(ryddlm}t j d|j}g}d}|j D]\}}t|dkDr|Dcgc]}|j}}d}|j|} t| ||D cgc]} | jc} |D cgc]} | jc} } |j| |j|d|syt|Scc}wcc} wcc} w)Nrrrc>t|tr |jSdSr1)rr_r`)xs r#z-_HLGExprSequence._tune_down..Ysz!W/Ea++4r%FTri)r2r,rjrrgroupbyrrfrrrrbr3r) rArgroupsexprsrrgrouprgraphsrZrr  hlg_groups r#rBz_HLGExprSequence._tune_downSs t}}  "6 O MM  &  ' Iu5zA~/45t$((55*n**F3)(11 >   Y' U1X& '''6!C >s-D D;Dcddlm}g}|jD]F}|j}|j}|j x} |||}|j |H|j|Sr)rjrr,rrfr`r3r)rArrhlgexprrrZrs r#rxz_HLGExprSequence._optimized_dskqst6}} G((*D++C$888 ET* MM#   $~##V,,r%c,t|jSr1)r rxr@s r#rz_HLGExprSequence.__dask_graph__s4..//r%c  |j}tt}|jj D]}|j s|j }|j D]Z\} t fd|D}||j|Dcic]\}}t|ts||c}}||rX||=\t|Scc}}w)Nc3LK|]}|tr|nfywr1)rz)rrrs r#rz8_HLGExprSequence.__dask_annotations__..s'"JK%U1XeE"s!$) rxrr@rryrrr+rrr) rArZr{r|r}r~annotsrrrs @r#rz%_HLGExprSequence.__dask_annotations__s!!CNtCTZZ&&( .s?2299;?r)rrr,r@s r#rz_ExprSequence._layers{{????r%c|g}|jD]*}|jt|j,|Sr1)r,r3r+rrs r#rz_ExprSequence.__dask_keys__s9-- 6B OOD!1!1!34 5 6r%c`ddjtt|jzdzS)Nz ExprSequence(rRrT)rUmaprMr,r@s r#r\z_ExprSequence.__repr__s&3tT]]+C!DDsJJr%c4td|jDS)Nc3<K|]}|jywr1)rHrs r#rz1_ExprSequence.finalize_compute..s <b!!# tjjSr1)rrrr@s r#_suffixzProhibitReuse._suffixZszz|r%c$t|tr|Dcgc]}|j|c}St|tr|j|df|ddzSt|tt fr t |}|d|jScc}w)Nrrr)rr+rr4r>floatr[r)rArkks r#rzProhibitReuse._modify_keys^s a 456bD%%b)6 6 5 !%%ad+-!"5 5 C< (AAAdll^$$ 7sB cnt|jt|js |jSyr1)rrr4_ALLOWED_TYPESr@s r#rzProhibitReuse._simplify_downgs2 II $%% & 99   r%c ddlm}t |j j }|Dcic]}||j|}}i}|jD]a\}}||}t||rtjdt|cSt|tj|j!|||<c|j#||S#t$rtd}YwxYwcc}w)Nr)P2PBarrierTaskzCannot block reusing for graphs including a P2PBarrierTask. This may cause unexpected results. This typically happens when converting a dask DataFrame to delayed objects.)distributed.shuffle._corerModuleNotFoundErrorrVr rrrrrrnrorrrrrr)rArrZold_keysubsdsk2new_keyrs r#rzProhibitReuse.__dask_graph__ps ( @#499#;#;#=>CFG**733GG $   GWG A!^, 4   '' T"DM " C 1# (!$ZN (HsCC-C*)C*N)rWrCrDrQr'r_rYrvrrrrFrrrrrrrrr?r%r#rrJsi (Kw(:rs" #%) 61==%2#   j j ZD4  '28B 0d 0l dl ^ G etePO'DO'd! ,d, 44nCDCr%