PiLddlZddlmZddlmZddlZddlmZm Z ddl mZ ddddZ ej d dddd Zejd d d ZdZejjej d dd ddedejdedede ejedfdede jdejfdZee_ejjdd ddedejde ejedfdede jdejf dZejjdd ddedejde ejedfdede jdejf dZejjdd ddedejde ejedfdede jdejf dZejjdd ddedejde ejedfdede jdejf dZdS)N)partial)util)CallableUnion)opbackendc\J|r|d}|dd}|d} n|d}|dd}dt||D}g} |D]\} } } }d| D}| |vr|| nd}|!|dksJ| | | | fcd| D}||=tjjj|} t|D]5}| | tdf|z|fz| | f6t| |j ksJ| }fdtfd|D}|r | |} |s |||n |||| S) Nrrc(g|]\}\}}}||||fSr ).0tensorcoordinate_axis_name expr_coordndims a/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/einx/op/index.py z_index..s> .sA   jtyGWG\6]6] I   rcZg|](}t|tjjj&|)Sr )rrrrrrs rrz_index..$s/aaaTD$)JZJ_9`9`aDaaarcBtj||ddS)NF) broadcastr r)rtranspose_broadcast)rrr expr_commons r transposez_index..transpose1s0' &+     rc38K|]\}}}||VdSNr )rrrrr%s r z_index..6sG$FF,@$ &$r)zipallindexappendrrrListmayberangeslicelenrtuple)updatelayoutexpr_update_innerr$rr tensors tensor_intensor_coordinates tensor_updatelayout2 tensor_coordrrr axis_namesraxesir%s ` ` @r_indexr? s     )AJ $QrT] AJ $QRR[@CDVX^@_@_FG@F< *J  ",.."2"2   7Kj6X6XJ  1 2 2 2^b  <19999 NNL*> K L L L LaaZ^^%5%5aaaDT ).44T::J4[[   %++$!6!!=>(   w<<9> ) ) ) ) F      JPD! -1BCC  >9())) R -} = =rcfdS)Nc2|fd|D|fi|S)Nc&g|] }|Sr r rxts rrz.....Es!,,,A11Q44,,,rr )exprs_in tensors_inexpr_outkwargscrEs rz..Ds@,,,,,,,hII:@IIrr rErJs``rrKrKDsr)tracec l  !"#t|t|kr/tdt|dt||dD]G}t|tjjjr!|jr|jdkrtdHt||gzD]L}| D]5}t|tjjj rtd6M|sJ| D]5}tjj |rtd6|rud|dd D}|d  D]F} t| tjjjr | j |vrtd | j Gd fd t||D}|}|d} |r |dd n |dd} |r|d } g} d}| D]}d | D}t|dkr#tdt|d|dt|dkr |djnd}t|dkr+|djr|djdkr |dj nd}| ||f||z }d| Dt|kr"td|dt|r@d| D}t|dkrtdd| D"t# "fd!!fd| D} |r%tjj| !nd} fd!tjj|!}|r%tjj| !} |r*fd!tjj|!}d##fd| D}|r #| nd}dt|| D} |r| d|dfgz}t'|dd fdd D}d |D}|D]\}}}| D]i} t| tjjjrC| j |kr8| j |vr/|| j || jtjjj|}n=tjjt1j|gd}tt4rt7t9t:|| ||!tj| g| z|r| gngz}tj|||gd"#\}}t|dkrt|dksJ|d|dfS)$N Expected z input tensors, got rr9First expression cannot contain unnamed axes with value 1zConcatenation not allowedz1Brackets in the output expression are not allowedch|]D}|D]-}t|tjjj&|j.ESr )r*rrrrrr)rrootrs r zindex_stage3..Xsa      $ 0 566  I    rr z\Update expression cannot contain axes that are not in the coordinate or tensor expressions: c|dkrdS|S)Nget_at embeddingr )ss rget_namezindex_stage3..get_namefs ==;Hrc g|][\}}tj||jt jt j\S))rinit)rtracer call_factoryshaper _op_to_str)rrrr rXrs rrz index_stage3..lsu    FD    J $/"--..$$ !     rcg|]L}t|tjjj&tjj|J|MSr )rrrrr is_markedrrs rrz index_stage3..s_" " " $ 0 566" <@9;K;U;UVZ;[;[" " " " rzCExpected at most one coordinate axis in coordinate expression, got z in ''ch|]Q}t|tjjj&tjj|J|jRSr rrrrrr`rras rrSzindex_stage3..s`     dDI,1 2 2 8.sa$ $ $ $ 0 566$ <@9;K;U;UVZ;[;[$ I$ $ $ rz,Update expression cannot contain marked axescdh|]-}t|tjjj&|j.Sr rras rrSzindex_stage3..sA:dDIDTDY3Z3Z rcRt|tjjjr}|jvrvtjj|sT|jtjj| SdSdSdSr') rrrrrrr`addMarker __deepcopy__)rnew_marked_axis_namestensor_axis_namess rreplacezindex_stage3..replaces tTY-2 3 3 @ !222I$..t443 " % %di 0 0 09#**4+<+<+>+>?? ?  @ @2222rcZg|]'}tjj|(Sr )rrrrm)rrrms rrz index_stage3..s.___T)11$@@___rct|tjjjrc|jvr\tjj|s:tjj|SdSdSdSr' rrrrrrr`rirj)rrks rrmzindex_stage3..replaces tTY-2 3 3 @ 222I$..t4439#**4+<+<+>+>?? ?  @ @2222rct|tjjjrc|jvr\tjj|s:tjj|SdSdSdSr'rp)rmarked_tensor_axis_namess rrmzindex_stage3..replaces4!1!677 DI!999 (22488:y'..t/@/@/B/BCCC  D D9999rctjj|}t j|gdS)Nr)rrr get_markedrflatten)rs rto_innerzindex_stage3..to_inners1y**400|TF##A&&rc&g|] }|Sr r )rrrvs rrz index_stage3..s!LLL$xx~~LLLrc$g|] \}\}}|||fSr r )rrrrs rrz index_stage3..s9 4J4-t z40rc6t|djS)Nr)r1r])rDs rrKzindex_stage3..sAaDJr)keyc~g|]9}t|tjjjr|jdk7|:S)rr)rrlongests rrz index_stage3..sS   $ 0 566 @DyGTUJ?V?V ?V?V?Vrch|] }|j Sr )rrs rrSzindex_stage3..s555Ddi555r)rr3r4r$r5r T)rflatr ) r1 ValueErrorrrrrr is_unnamedvaluelistr* Concatenationr`rr) all_to_tensorr,setrmsortedrhr-r.rtrrustrgetattrrr?rM vmap_stage3)$rFrGrHr3rr rrRr<r expr_tensorexprs_coordinates expr_updater4 total_ndimrmarked_coordinate_axesrrmarked_update_axis_namesexprs_coordinates_innerr5r:all_axes axes_names_r$ tensors_out exprs_outrXr|rrrkrmrlrvs$ `` @@@@@@@r index_stage3rCs  8}}J''YS]]YYJYYZZZ ZZ dDI,1 2 2 Zt Z4:YZ??XYY YX(+>>HHJJ > >D$ 0 >?? > !<=== > > VLLNN V VDy))$// V !TUUU V    "    RL$$&&  D$ 0 566 49J;V;V E9=EE        H55   J&&z22J1+K*0B2hqrrl #rl FJ' " " "((" " "  % & & * *G122GG9CGGG 366L2M2MQR2R2R%a(..XY)**a//+A.90=STU=V=\`a=a=a #1 % * *   +T2333d   OO%%     #$$ 22 _ _ _D\@]@] _ _   M$ $ #))$ $ $  ' ( (A - -KLL L)oo// EE@@@@@@`___M^___DJT$)"**;@@@PTK@@@@@y'''::H Ei&..{GDD  ? D D D D D9#++Hg>>'''MLLL:KLLL17A---T8;9Q< ''rT)csectjj||\}}tjj|}t|dkrmr\tjj|dtjj |ddgg}ntdt|dtkr5tdt|ddtt|ddkr%tdt|dfd}tj dt|dDtj |ddgzd |Dz|| dt|ddz}|dt|d|t|d} }rld |dD} d | D} | | std | | z || fS)Nrrz2Operation string must contain an output expressionrOz input tensors, but got z&Expected 1 output expression, but got c|dD]d}t|tjjjr>|jdkr3tjj|rtded|dD}t|}g}|dt} r |dd}|D]T}d|dD}t|dkrtdt|t|dkrt|dtjjj rC| tjj |dj | tjj |dj| tjj dVtjtjj j|t#j|ggS)NrrrPcg|]b}t|tjjjtjjjf.after_stage2..+sj   $!1!;TY=M=Y Z[[   **400     rr cg|]b}t|tjjjtjjjf.after_stage2..9sj&&&dTY%5%?AQA]$^__&I$..t44 &&&&rz.after_stage2#sy1IMMOO ^ ^D4!1!=>> ^J!OOI$..t44$!!\]]]  q     %&& Q]!3!334  +%crc*K D DD&&"1IMMOO&&& " )**Q.. ; !788;;+,,114Q79I9STT&&ty'7'A'ABXYZB[B`'a'abbbb&& (445KA5N5TUU""49#3#?#?#B#BCCCC I    .44[AA2:tfCUCU    rcTg|]%\}}tj||&Sr )rrr)rexpr_in tensor_shapes rrzparse..Us>   % I  w 5 5   rcg|]L\}}tj|tj|dtjfddMS).N)depth1depth2)rrrrrnewaxis)rkvs rrzparse..ZsY   1 I  q"*Q--RZ"@VZ  [ [   r)rrcdh|]-}t|tjjj&|j.Sr rrs rrSzparse..esA   z$ HXH]7^7^ I   rcdh|]-}t|tjjj&|j.Sr rrs rrSzparse..hs1ddd$JtTYM]Mb.ts&$;$;Q!V$;$;$;$;$;$;r)rr[ get_shapeany)rr]s r_has_zero_shaperrs> K ! !& ) )E   ;$;$;U$;$;$;!;!;;rcddfd S)N)r c4|gfd|DRi|S)Nc&g|] }|Sr r rCs rrz.....zs!---qqtt---rr )rr r6rIrJrEs rrKz..ysJQQN----W---NNN17NNrr rLs``rrKrKys+Tr)r rrr6rr3r rrreturnc|r)td|ddDr|dSt|gd|DR||d|\}}t||||||\} }| S)a> Updates and/ or returns values from a tensor at the given coordinates. * If ``update`` is True: The first tensor receives updates, the last tensor contains the updates, and all other tensors represent the coordinates. If the output expression is not given, it is assumed to be equal to the first input expression. * If ``update`` is False, values are retrieved from the first tensor and the remaining tensors contain the coordinates. Using multiple coordinate expressions will yield the same output as concatenating the coordinate expressions along the coordinate axis first. Args: description: Description string for the operation in einx notation. *tensors: Tensors that the operation will be applied to. op: The update/gather function. If ``op`` is a string, retrieves the attribute of ``backend`` with the same name. update: Whether to update the tensor or return values from the tensor. backend: Backend to use for all operations. If None, determines the backend from the input tensors. Defaults to None. cse: Whether to apply common subexpression elimination to the expressions. Defaults to True. graph: Whether to return the graph representation of the operation instead of computing the result. Defaults to False. **parameters: Additional parameters that specify values for single axes, e.g. ``a=4``. Returns: The result of the update/ gather operation if ``graph=False``, otherwise the graph representation of the operation. Examples: Get values from a batch of images (different indices per image): >>> tensor = np.random.uniform(size=(4, 128, 128, 3)) >>> coordinates = np.ones((4, 100, 2)) >>> einx.get_at("b [h w] c, b p [2] -> b p c", tensor, coordinates).shape (4, 100, 3) >>> tensor = np.random.uniform(size=(4, 128, 128, 3)) >>> coordinates_x = np.ones((4, 100), "int32") >>> coordinates_y = np.ones((4, 100), "int32") >>> einx.get_at( ... "b [h w] c, b p, b p -> b p c", ... tensor, ... coordinates_x, ... coordinates_y, ... ).shape (4, 100, 3) Set values in a batch of images (same indices per image): >>> tensor = np.random.uniform(size=(4, 128, 128, 3)) >>> coordinates = np.ones((100, 2), "int32") >>> updates = np.random.uniform(size=(100, 3)) >>> einx.set_at( ... "b [h w] c, p [2], p c -> b [h w] c", tensor, coordinates, updates ... ).shape (4, 128, 128, 3) >>> tensor = np.random.uniform(size=(4, 128, 128, 3)) >>> coordinates_x = np.ones((100,), "int32") >>> coordinates_y = np.ones((100,), "int32") >>> updates = np.random.uniform(size=(100, 3)) >>> einx.set_at( ... "b [h w] c, p, p, p c -> b [h w] c", ... tensor, ... coordinates_x, ... coordinates_y, ... updates, ... ).shape (4, 128, 128, 3) c34K|]}t|VdSr')rrrs rr(zindex..s*HH&of--HHHHHHrrNrcLg|]!}tj|"Sr )rr[rrs rrzindex..s( > > >F$+   ' ' > > >r)r3r)rr3r )rrr) rrr3r rr6rrFrHrs rr+r+wsn#HHGABBKHHHHHqz > >g > > >    Hh$'867FH Mrc,t|g|Rdd||d|S)zNSpecialization of :func:`einx.index` with ``op="get_at"`` and ``update=False``rUFrr3r rr+rr rr6rs rrUrUsA    "*5's  V`  rc,t|g|Rdd||d|S)zMSpecialization of :func:`einx.index` with ``op="set_at"`` and ``update=True``set_atTrrrs rrrA    "*4c  U_  rc,t|g|Rdd||d|S)zMSpecialization of :func:`einx.index` with ``op="add_at"`` and ``update=True``add_atTrrrs rrrrrc,t|g|Rdd||d|S)zRSpecialization of :func:`einx.index` with ``op="subtract_at"`` and ``update=True`` subtract_atTrrrs rrr sB    "/gSV  Zd  r)r functoolsrrnumpyrtypingrr numpy.typingnptr?jitr lru_cacherrtraceback_utilfilterrTensorboolBackend ArrayLiker+rUrrrr rrrs """"""""IMVZ77777t    @DTA(A(A(A(  A(H37bbbbbJ<<<    /3 ^^^^k^ ^  ^ 4<d* + ^  ^-^ [^^^  ^B /3    k 4<d* +    -   [    /3    k 4<d* +    -   [    /3    k 4<d* +    -   [    /3    k 4<d* +    -   [      r