bi<ddlmZddlZddlZddlmZddlmZddlZ ddl Z ddl m Z ddlmZddlmZddlmZddlmZe j,d d Zd Zd Zd ddddddddddddddddddd d!d"d#d$d%d&d'gZe j6j9d(ed)Zd*Ze j6j9d(ee j6j?d+eed,Z e j6j9d(ee j6j?d+eed-Z!d.Z"d/Z#d0Z$d1Z%e j6j9d2d3e j6j9d4gd5d6Z&e j6j9d2d3e j6j9d4gd5d7Z'e j6j9d4d8d9gd:Z(d;Z)d<Z*d=Z+d>Z,e j6j9d?d@dAgdBZ-dCZ.dDZ/e j6j9dEgdFdGZ0dHZ1dIZ2y)J) annotationsN)deepcopy)product)ComplexWarning) assert_eq)tokenize)typenamez dask.array.mactjjgdgdd}tjjgdgdd}tjjgddd}t|t|k(sJt|t|k(sJt|t|k(sJt|t|k7sJt|t|k7sJy)NTTF mask fill_valuerF)npma masked_arrayr)mm2m3s W/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/dask/array/tests/test_masked.pytest_tokenize_masked_arrayrs 9+>2NA   I,?A  NB   IEb  AB A;(1+ %% % B<8B< '' ' B<8B< '' ' A;(2, && & A;(2, && &ctjjgdgdd}tj|dd}t ||y)Nr rrr)r Fchunksasarray)rrrda from_arrayr)rdms rtest_from_array_masked_arrayr$s: 9+>2NA qu 5B b!rc0tjjddgddg}tj||j d}|j }i}t||}tjjddgddg}t||t||t|jtjjsJt||t|jtjjsJy) Nr r rrFr)memoT) rrrr!r"shapecopyr masked_wherer isinstancecompute)txyr'y2xxs rtest_copy_deepcopyr2%s Aq6A/A a7A A D !$ B   UDMAq6 2B a aO aiik255#5#5 66 6 b! bjjlBEE$6$6 77 7rc|SNr.s rr77sarc,tj|Sr4)r!expm1r6s rr7r78sbhhqkrc d|zSNr r5r6s rr7r79 a!erc |dz Sr;r5r6s rr7r7:r<rc |dzSr;r5r6s rr7r7;s adrc ||zSr4r5r6s rr7r7<r<rc ||zSr4r5r6s rr7r7=r<rc |dS)Nrr5r6s rr7r7>s adrc|dddfSNr r5r6s rr7r7?sa1grc|dddddfS)Nr rr5r6s rr7r7@saD!A# rc|jSr4)Tr6s rr7r7As accrc.tj|dS)N)r r r)r! transposer6s rr7r7Bsbll1i(rc"|jSr4sumr6s rr7r7Cs aeegrcd|jtj|jdSN)dotraranger(r6s rr7r7Ds aeeBIIaggbk*+rcd|jtj|jdSrM)rOreyer(r6s rr7r7Es aeeBFF1772;'(rcvtj|tj|jddddgS)Nr )rr axes)r! tensordotronesr(r6s rr7r7Fs+bll1bggaggbqk2&&9IJrc&|jdSNraxisrJr6s rr7r7Gaeeemrc&|jdSrY)maxr6s rr7r7Hr\rc&|jdS)Nr r rZrJr6s rr7r7Isaeee rc@|jtjSr4)astyper complex128r6s rr7r7Jsahhr}}%rc&|jdS)Nc |dzSr;r5r6s rr7z..Ks QUr) map_blocksr6s rr7r7Ksall?+rc$|jdSrC)roundr6s rr7r7Lsaggajrc||j|jd|jdz|jdfS)Nrr r )reshaper(r6s rr7r7Ms1aiiaggaj0!''!*=>rct|Sr4)absr6s rr7r7Ns c!frc |dkDS)N?r5r6s rr7r7Os a#grc$|jdS)N)rprprechunkr6s rr7r7Paii "rc$|jdS)Nr r r rqr6s rr7r7Qrsrfuncctjjjdd}d||dk<tjj |d}||}||}t |tjj |d|jr7|j}t|tjjsJyy)Nr rrpr r r rr皙?) r!random default_rngr masked_equalrfilledr(r,r+rr)rvr.r/r1yyzzs r test_basicrUs &&y&CAAa#gJ 1a A aB aB b"%%,,r1%& xx ZZ\"bee00111rc 0tjj}|jdd}d||dk<|jdd}d||dk<tjj |d}tjj |d}t tj ||d tjjtj ||d dt tj ||d tjjtj ||d dt tj ||d tjjtj ||d dy) Nrxryrzrr{)rprr ru)r rrTr r )r`)r r)r!r|r}rr~rrVr)rngr.r/r1rs rtest_tensordotrfs) ))   !C 9Y /AAa#gJ 9Y /AAa#gJ   Aq !B   Aq !B  Q'  R\\"bv6: Q'  R\\"bv6: Q 01  R\\"b/?@!Drzignore::c~tjj}|jdd}|jdd}d||dk<tjj |d}tj ||gd}tj ||gd}||}||}t ||ddy) Nrxryrzrr{rZF check_meta check_type)r!r|r}rr~ concatenater) rvrr.r/rdsddsss rtest_mixed_concatenater~s ))   !C 9Y /A 9Y /AAa#gJ   Aq !B 1vA&A 2wQ'A aB aB b"59rctjjjdd}d||dk<d}|j|}||}||}t ||ddy) N)rprrpryrzrr{cttjdkr tjj|dS|S)Nrnr)r|rrr~r6s rr7z#test_mixed_random..s(v}}/D255%%a+!rFr)r!r|r}rfr)rvrfnrrrs rtest_mixed_randomrsf &&y&CAAa#gJ KB RA aB aB b"59rctjjjdd}d||dk<tjj |d}tj dd}tj ||gd }|jd k(sJ|j}t|tjjsJy) Nrrrrzrr{)rr )rr r rZ)r ) r!r|r}rr~zerosrr(r,r+rr)r/r.zrs rtest_mixed_output_typers &&x&?AAa#gJ 1a A (A 1vA&A 77h   B b"%%,, -- -rc tjgddzjd}tjgddz}tj|d}tj|d}tj j ||}t||g||gD]/\}}ttj j |||1ttj j |d tj j |d ttj j|d tj j|d ttj j|d tj j|d ttj j|d tj j|d ttj j|d tj j|d ttj j|d tj j|d ttj jd |tj jd |ttj j|dkD|tj j|dkD|tj t"5tj j|dkDddd f|dddttj j%|d d tj j%|d d ttj j'|d d tj j'|d d ttj j)|d tj j)|d tj t*5tj j||dddtj t*5tj j)||ddd|j-d }tj.x|d<|d<tj|d}ttj j1|tj j1|tj j |d }tj j |d }ttj j3|d tj j3|d y#1swY{xYw#1swYjxYw#1swY5xYw)NrNrr r r)rrr r rr rrzrprFrNr f8rr)rr)rarrayrjr!r"rmasked_greaterrrmasked_greater_equal masked_lessmasked_less_equalr~masked_not_equalr*pytestraises IndexError masked_insidemasked_outside masked_values ValueErrorrbnanmasked_invalid fix_invalid) r.r/dxdysolabmydmys rtest_creation_functionsrs  "R'(00:A !A%&A q #B q #B %%  q! $CQ"a)31"%%&&q!,c23bee""2q)255+?+?1+EF bee((Q/1K1KAq1QR beeA&(9(9!Q(?@ bee%%b!,bee.E.Ea.KL bee  Q'););Aq)AB bee$$R+RUU-C-CAq-IJbee  +RUU-?-?q-IJ bee  a,bee.@.@Q.JK z "/ BFAqD>2./bee!!"b!,bee.A.A!R.KL bee""2r1-ruu/C/CAr1/MN bee!!"b)255+>+>q"+EF z "# 2r"# z "$ B#$ AAdGag q #B bee""2&(<( bee  $bee&8&8&;< beemmC "%%--"34 beemmBq!12rc ,tjjjdjd}t j |d}t j tj dd}ddd|fg}t||g|D]C\}\}}ttjj|| tjj|| ttjj||d kD| tjj||d kD| ttjj||d kD| tjj||d kD| ttjj||d tjj||d Ftjt5tjj|| dddtjtjj5tjj||ddddfdddy#1swYjxYw#1swYyxYw)Nrf4rrzr r5)NN)rnrnrr{rr)rrrr&)rr|r}rbr!r"rrrrrrrr MaskError)r.rf1 fill_valuesdatadffs rtest_masked_arrayrGs &&x077=A q (B rxx{2 .BaW5K !R+6 gr1 EE  t  3RUU5G5GVW5G5X   EE  t$*  D EE  qq3w1  =   EE  t$*  D EE  qq3w1  =   EE  t$  ? EE  qQd  ;  " z ". 2"-. ruu '0 2Brr2A2vJ/00..00s3"I> +J >J Jcxtjjjddd}t j |d}tj j|d}tj j|d}tj j|dtj j|dt||tj j|dtj j|dt||tjt5tj j|ddddtjt5tj j||dddy#1swYLxYw#1swYyxYw) Nrrrrrzrig@xD)rr|r}integersr!r"rrset_fill_valuerrr TypeErrorrrs rtest_set_fill_valueres4 ((B9A q (B   a #B %%  r1 %CEEc"EES!bEES!EEC Q y !( S$'( z "& S"%&&((&&s8!F$:!F0$F-0F9rFTc  tjddgddgddgg}tjdjd}tjj||}t jj ||d}tjdd g}t j|d }t jj||d | }t|tjj||d | y) NTFrrr r&r rrrg?g?rzr )weightsr[r) rrrPrjrr!rr"averager)rrrrd_ar d_weightsda_avgs r&test_average_weights_with_masked_arrayrzs 88dE]T4L5$-@ AD 99Q<   'D  Dt $A %%  $T!  ! !( +D 1HMdQh!m ,D 4&A q (Beekk"4k(eekk!$k'#s %%++b4+ (C %%++a$+ 'C c3 "A q (B beekk"oruu{{1~. #x(A tF +BAeekk"4k(eekk!$k'#s (?@Arfuncname) ones_like zeros_like empty_likecXtjddgddgddgg}tjdjd}tjj||}t jj ||d}tt j|}ttjj|}||}||}d|vrGtt jj|tjj|yt||y) NTFrrr&r rempty) rrrPrjrr!rrcorerr) rrrrrda_funcnp_funcrrs rtest_like_funcsrs 88dE]T4L5$-@ AD 99Q<   'D  Dt $A %%  $T!  @ST UD  Dt $A %%  $T!  rEs"  2&O$' 8$(+(J %+>""7  >+ 2, 2 0+hx'?&@AB :C, : +hx'?&@AB :C, : ./Yd; (,/R00,/R%0%x&:; -< -D 30<&*eT]3 T4 T 9A:%NOP$&,r