Cd81ddlmZddlZddlZddlmZddlmZddl m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZdd lmZmZe jeejfej ejeejfej!e jeejfej"e jeejfej#e jej$j%ej$j#e jeejfee jej$j%eejejd)d Z&e jej$j%d*d Z'ejej$j%d+dZ(ej)de j)dej)dej)dej)ddZ*ej)de j)ddZ+ej)de j)dej)dej)ddZ,ej)de j)ddZ-dZ.ejej$j%dZ/ejeejfdZ0dZ1d,dZ2ejeejfdZ3dZ4Gd d!eZ5ejejd"Z6Gd#d$e5Z7ed%d&e5d'(Z8e89d&e7dS)-) annotationsN)chunk)Array) concatenate_lookup divide_lookup einsum_lookup empty_lookupnannumel_lookup numel_lookuppercentile_lookuptensordot_lookupto_cupy_dispatchto_numpy_dispatch)divide) ma_divide _percentile)CreationDispatchDaskBackendEntrypointlinearc$t|||SNr)aqmethods 3lib/python3.11/site-packages/dask/array/backends.py percentiler#s q!V $ $$ctj||}d|D}td|Drt d|r4tj|}t |dkr |d|_|S)N)axisc<g|]}t|d|jS) fill_value)hasattrr").0is r z _concatenate..+s)LLLA71l3K3KL1<LLLrc3JK|]}t|tjVdSr) isinstancenpndarray)r$fs r z_concatenate..,s. : ::a $ $ : : : : : :rzADask doesn't support masked array's with non-scalar `fill_value`sr)r)ma concatenateany ValueErroruniquelenr")arraysr out fill_valuess r _concatenater7(s %  F  . .CLLLLLK : :k : : :::  O   ,i ,, {  q (^CN Jrc t||\nK#t$r>tt| dttd|YnwxYw t }tn#t$rgd}YnwxYw t }tn#t$rgd}YnwxYw|j|j}|j|j}d}||krd}nlt|D]\}||krd}n9|dkr|xx|z cc<|dkr|xx|z cc<]|stdfdt|D} | z} d} D] } | | z} d| f} fd| D}fd t|D} | z}d} D] } | | z} | df}fd | D}||  | }|| |}tj ||}| ||zS) Nrr-TFzshape-mismatch for sumcg|]}|v| Sr;)r$kaxes_as rr&z_tensordot..f 6 6 61avooQooorc g|] }| Sr;r;)r$r as_s rr&z_tensordot..ls ( ( ($CI ( ( (rcg|]}|v| Sr;r;)r$r<axes_bs rr&z_tensordot..nr>rc g|] }| Sr;r;)r$r bss rr&z_tensordot..ts ' ' 'BtH ' ' 'r) iter TypeErrorlistranger3shapendimr1 transposereshaper)r.dot)rbaxesnanbndandbequalr<notin newaxes_aN2r newshape_aolda newaxes_b newshape_boldbatbtresrAr=rCrEs @@@@r _tensordotra8s T  &&&eTE1oo&&eAtnn%%&  [[f   [[f   'C &C B &C E Rxxr ! !A6!9~F1I..ay1}}q S ay1}}q S 31222 7 6 6 6c 6 6 6EI B c$ibJ ( ( ( (% ( ( (D 6 6 6 6c 6 6 6EI B bhbJ ' ' ' ' ' ' 'D Y   ' ' 3 3B Y   ' ' 3 3B %))B  C ;;td{ # ##s4AA#"A#'BBBB;;C  C cupyc(ddltjjjt jjjtjjttjjttjjttjjfd}tjtjfd}t!jjfd}dS)Nrc j|fi|Sr)asnumpydatakwargsrbs r cupy_to_numpyz$register_cupy..cupy_to_numpyt|D++F+++rc j|fi|Sr)asarrayrfs r numpy_to_cupyz$register_cupy..numpy_to_cupyrjrcv|dd|ddj|i|S)Ncastingorder)popeinsum)argsrhrbs r _cupy_einsumz#register_cupy.._cupy_einsumsD  9d### 7D!!!t{D+F+++r)rbrregisterr*r/r tensordotr rr _numel_arrayliker _nannumelrrr)r)rirmrtrbs @r register_cupyry|s KKK d.>???dlDN;;;t|Z888$,(8999T\9555 --,,,,.-,rz**,,,,+*,DL)),,,,*),,,rcupyxcddlm} ddlmmn"#t$r}t d|d}~wwxYwdfd }t j||tj|tdS)Nr)spmatrix)hstackvstackz>Stacking of sparse arrays requires at least CuPy version 8.0.0cp|dkr |S|dkr |Sd|z}t|)Nrr-zECan only concatenate cupy sparse matrices for axis in {0, 1}. Got %s)r1)Lr msgr}r~s r_concat_cupy_sparsez+register_cupyx.._concat_cupy_sparsesQ 1996!99  QYY6!99 "$() S// !rr) cupyx.scipy.sparser|r}r~ ImportErrorrrur _tensordot_scipy_sparse)r|err}r~s @@rregister_cupyxrs,+++++555555555  L    " " " " " " "*=>>>h(?@@@@@s 2-2sparsecddl}tj|j|jt j|j|jtj|jttj|jtdS)Nr) rrruCOOr/r rvr _numel_ndarrayr _nannumel_sparse)rs rregister_sparsersp MMM F,>???fj&*:;;;&*n555VZ)9:::::rscipycddldfd }tjjj|t jjjt dS)Nrc|dkrj|S|dkrj|Sd|z}t|)Nrr-zFCan only concatenate scipy sparse matrices for axis in {0, 1}. Got %s)rr~r}r1)rr rrs rr7z+register_scipy_sparse.._concatenatesa 199<&&q)) ) QYY<&&q)) )"$() S// !rr) scipy.sparserrurr|r r)r7rs @rregister_scipy_sparsersh " " " " " " 5|DDDel35LMMMMMrc|j|jcxkrdksnJt|dt|dcxkrdksnJ|d\}|d\}|dvr|dvsJ|j||j|ksJ|dkr|dkr |j|zS|dkr|dkr|j|jzS|dkr |dkr||zS|dkr|dkr ||jzSdSdS)Nr8rr-)rr-)rKr3rJT)rrOrPa_axisb_axiss rrrs. 6QV q tAw<<3tAw<< , , , ,1 , , , , , ,QIVQIV V  & 0 0 0 0 76?agfo - - - - {{v{{sQw 11sQSy 111u 1113w rc Jtjtj|fi|S)z'Numel implementation for masked arrays.)rsumr) ones_likexrhs r _numel_maskedrs$ 9R\!__ / / / //rc  t|fddi|S)zJNumel implementation for arrays that want to return numel of type ndarray.coerce_np_ndarrayT_numelrs rrrs ! 6 6t 6v 6 66rc  t|fddi|S)zKNumel implementation for arrays that want to return numel of the same type.rFrrs rrwrws ! 7 7u 7 7 77rrboolc p|j|dd}|dd|dtj}mtj|}|dur|S|r'tjdt z||Stj||dt z| Stttfsgtjfd D}|d ur7tfd tt D}n6tfd tt D}|r)tj tj|||Stj|||| S)a  A reduction to count the number of elements. This has an additional kwarg in coerce_np_ndarray, which determines whether to ensure that the resulting array is a numpy.ndarray, or whether we allow it to be other array types via `np.full_like`. keepdimsFr Ndtype)r)r-)rJr"r)rJrc3(K|] }|V dSrr;)r$dimrJs rr,z_numel..s'00CU3Z000000rTc34K|]}|vr|ndVdS)r-Nr;r$rr rJs rr,z_numel..sD  58#T//E#JJq      rc30K|]}|v|VdSrr;rs rr,z_numel..s,UUSPT__%*____UUr)rJgetr)float64prodfullr3 full_liker(tuplerHmathrI broadcast_toarray) rrrhrrr new_shaper rJs @@rrrs GEzz*e,,H ::fd # #D JJw + +E |wuE*** u  K  O7E !2t5QQQ Q<4tc%jj/@NNN N dUDM * *v 900004000 0 0D4     rs"""""" !!!!!!                        877777------------AAAAAAAAVRZ0".AAA62:. ===  +RY777 vrz*BH555 be("%+666  +Y777 ru)9555BJ''%%%('%RU/00   10 25-..@$@$@$/.@$F ''!!&))v&&F##  ((,,)($#'&*)(' ,2 ((!!'**AA+*)(A4 ))!!(++x((H%% ; ;&%)(,+*) ; ((!!'**NN+*)(N&"ru)**00+*0  +,,77-,7 888 %C%C%C%CP62:.////0// 7 7 7@"@"@"@"@"2@"@"@"FBJ''('3*+* + " ((2H2H2J2JKKKKKr