U md}<@sddlZddlZddlmZmZmZmZmZddl m Z ddl m Z mZddlmZmZmZddlmZddZdd Zd d Zd d Zejddedddddddddejg ifdejdddddddddejg ifdejdddddddddejg ifdejddddddddd ejg d!d"ifd#ej dddd$d%d&ddd'ejg d!d"ifd(ej!ddddddddd)ejg ifgd*d+Z"d,d-Z#ejd.d/dddd0dd1ddejejg fd2dddd3d4d5ddejejg fgd6d7Z$ejd8d9dddddd:ddddg gd;dddddZ%d?d@Z&ejdAd"dd"d"dBdCgfdDdd"ddBd"gfgejdEd(gfdFd'gfgdGdHZ'ejdIeeegejdJd"dCdKgejdLd"d"gdd"gdMd"dCgdd"gdMd"gdNejd"dCejge(e)dOdNdMgdPdQZ*ejdRd"d"dgd"gfd"dCdd"gd"dCgfdCd"dgd"gfdCdCdd"gdCdCgfdSdKe)dKe(e)dSdKdKgdSfdKdSe)dSdSgdSfdde+ge+gfd"de+ge+gfdd"dgdgfg dTdUZ,ejdVedd"dCgd"dCdCgdWdCeddXdgej-d"dCdCge)dBgdYdgdZd[ej.d\feejd"dCejge(e)dOd]d"gd^dCgd_e)d]d`dKedadadbd.BadIndexercSsdSN)selfrr^/home/sam/Atlas/atlas_env/lib/python3.8/site-packages/pandas/tests/window/test_base_indexer.pyget_window_boundsszJtest_bad_get_window_bounds_signature..BadIndexer.get_window_boundsN__name__ __module__ __qualname__rrrrr BadIndexersrzBadIndexer does not implementmatch)rpytestraises ValueErrorrrangerolling)rindexerrrr$test_bad_get_window_bounds_signaturesr cCs<ttd}t}||}|}t||dS)N )rrr rmeanZ expandingtmassert_series_equal)srresultexpectedrrrtest_expanding_indexer#s   r(cCsndddddg}tdtdi}Gdddt}|d|d}||}tdd d d d d gi}t||dS) NTFvaluesrc@seZdZddZdS)z3test_indexer_constructor_arg..CustomIndexerc Ssltj|tjd}tj|tjd}t|D]:}|j|rLd||<|d||<q(|||<||j||<q(||fSNdtyper)npemptyint64r use_expanding window_size r num_values min_periodscenterclosedstepstartendirrrr1s  zEtest_indexer_constructor_arg..CustomIndexer.get_window_boundsNrrrrr CustomIndexer0sr<r-r2r1?@$@rrrrsumr#assert_frame_equal)r1dfr<rr&r'rrrtest_indexer_constructor_arg+s rFcCshtdtdi}Gdddt}|dd}|j|ddddd }tdd d d d dgi}t||dS)Nr)rc@seZdZddZdS)z8test_indexer_accepts_rolling_args..CustomIndexerc Sstj|tjd}tj|tjd}t|D]P}|rb|dkrb|dkrb|dkrb|dkrbd||<|||<q(|||<||j||<q(||fS)Nr+r-bothr)r.r/r0rr2r3rrrrGs$  zJtest_indexer_accepts_rolling_args..CustomIndexer.get_window_boundsNrrrrrr<Fsr<r-r2TrG)r6r5r7r8r>r?rAr@@rB)rEr<rr&r'rrr!test_indexer_accepts_rolling_argsCs  rKzfunc,np_func,expected,np_kwargscountr@g@minr>r?rJg@g@g @maxY@g"@stdgK@gDmK@g!?J@g'e?Zddofr-varg[{@@g[{@g[{Ħ@g?mediang!@c sNtd}d|d<tdd}d}tjt|d$||j|dd } t| |W5QRXd }tjt|d$||j|d d } t| |W5QRX||j|d |d} t| |} ||dd|}t | ||| fdd} t | | |dkrdnd} ||j|| d} t| |}|| fdd}t ||dS)NrArOrrIz.Forward-looking windows can't have center=TruerT)windowr6zAForward-looking windows don't support setting the closed argumentright)rTr7rHrTr5r8cs |fSr rxnp_func np_kwargsrrz-test_rolling_forward_window..rLrrTr5cs |fSr rrWrYrrr\r]) r.arangerrrrrgetattrr# assert_equalapply)frame_or_seriesfuncrZr'r[r8r)rrrr&Z expected2r5Zrolling3Zresult3Z expected3rrYrtest_rolling_forward_windowas,9      rec Csrtd}d|d<tdd}||j|d|d}|}|ddd d d d ddtjtjg dd|}t||dS) NrArOrrIrSrVr>g o@g\QJ@g@gv-@gA @)r.r_rrZskewnanr#ra)rcr8r)rrr&r'rrrtest_rolling_forward_skewnesss*   rgz func,expectedcovg@X@g@Wcorrg?gh"?g1=cCstddd}|d}d|d<tj||gdd}tdd }t|j|dd }t||jt ddfd f}|j d d }t |j d d }|j |_ t ||dS)Nr!r-rHd)rr)ZaxisrSrIr^rT)Zdrop)r.r_ZreshapeZ concatenaterrrr`locsliceZ reset_indexrnamer#ra)rdr'Zvalues1Zvalues2r)rrr&rrrtest_rolling_forward_cov_corrs  rozclosed,expected_datarUg(@leftg@cCs^tddd}ttd|d}td}t||d}|j||d}t||d}t||dS)NZ2020r!)Zperiods)indexr-)rqoffset)r7) rrrr r rrCr#rD)r7Z expected_datarqrErrrr&r'rrr&test_non_fixed_variable_window_indexers   rscCs`tdddddgi}tdd}|j|d|d}tdddddgidd|}t||dS) NbrHrIrrVr>r?)rrrrLr#rD)r8rErr&r'rrr test_fixed_forward_indexer_counts  rv) end_valuer)rSrHrj)rdargsZquantilec snGfdddt}dddddg}tdtdi}|d|d}t||||}td|i} t|| dS) NcseZdZfddZdS)z0test_indexer_quantile_sum..CustomIndexerc srtj|tjd}tj|tjd}t|D]@}|j|rRd||<t|d||<q(|||<||j||<q(||fSr*)r.r/r0rr1rNr2r3rwrrrs  zBtest_indexer_quantile_sum..CustomIndexer.get_window_boundsNrrryrrr<sr<TFr)rr-r=)rrrr`rr#rD) rwr)rdrxr<r1rErr&r'rryrtest_indexer_quantile_sums   rz indexer_classr2 df_data)artcCsXt|}d}||d}|j}t|D].}|ddj|dd|j|ks$tq$dS)NrSrIr~rtr-r^)rr2rgroupbyrr"AssertionError)r{r2r}rEZ num_trialsrZoriginal_window_sizer;rrr0test_indexers_are_reusable_after_groupby_rolling4s  rz5window_size, num_values, expected_start, expected_endrcCstt|d}|j||d\}}tj|t|dd|ddtj|t|dd|ddt|t|ksptdS)NrI)r4r8F)Z check_dtype)rrr#Zassert_numpy_array_equalr.arraylenr)r2r4Zexpected_startZ expected_endr8rr9r:rrr!test_fixed_forward_indexer_boundsMs  rzdf, window_size, expected)rtr~g?r~)namesrt)rqrnr,ru )rtr~cg @g@g@g)@g*@g+@g,@g-@g.@g/@g0@g0@g1@cCs6t|d}|ddj|dd}t||dS)NrIr~rtr-r^)rrrr"r#r$)rEr2r'rr&rrr0test_rolling_groupby_with_fixed_forward_specificis6 r group_keys)r-)r-rH)rHr-)r-r-rH)r-rHr-)r-r-rHrH)r-rHrSrHrS) r-r-rHr-r-rHr-r-rHr-r-rH)r-rHrSr-rHrSr-rHrSr-rHrSr-rHrScsttt|tjt|tjddtjt|tjdd}td}| ddj |dd }dd g|j _ | dddd g}tfd d |D}|dd gd}t||dS) Nr+)r~rtrrIr~rtr-r^rcs4g|],\}jfddttDdqS)cs*g|]"}dj||jddqS)rtr-)Z min_count)ZilocrC).0r;)gr2rr szKtest_rolling_groupby_with_fixed_forward_many...)rt)Zassignrr)r_rI)rrrs   z@test_rolling_groupby_with_fixed_forward_many..)rr.rlistr_rfloat64r0rrrrCrqrrZ set_indexr#r$)rr2rErr&groupsZmanualrrIr,test_rolling_groupby_with_fixed_forward_manys"     rc CsGdddt}|}td|}d}tjt|d|W5QRXtjt|dtt|W5QRXtjt|d|j ddW5QRXtjt|d|j ddW5QRXdS)Nc@seZdZddZdS)z4test_unequal_start_end_bounds..CustomIndexercSstdgtddgfSNr-rHr.rrr4r5r6r7r8rrrrszFtest_unequal_start_end_bounds..CustomIndexer.get_window_boundsNrrrrrr<sr<r-r9rTpairwise rrrrrrr"nextiterrirhr<rZrollrrrrtest_unequal_start_end_boundssrc CsGdddt}|}tddg|}d}tjt|d|W5QRXtjt|dtt|W5QRXtjt|d|j ddW5QRXtjt|d|j ddW5QRXdS)Nc@seZdZddZdS)z4test_unequal_bounds_to_object..CustomIndexercSstdgtdgfSrrrrrrrszFtest_unequal_bounds_to_object..CustomIndexer.get_window_boundsNrrrrrr<sr<r-z start and endrTrrrrrrtest_unequal_bounds_to_objectsr)3numpyr.rZpandasrrrrrZpandas._testingZ_testingr#Zpandas.api.indexersrrZpandas.core.indexers.objectsr r r Zpandas.tseries.offsetsr r r(rFrKmarkZ parametrizerrfrMrNrPrQrRrergrorsrvrzrrrrrZ from_arraysrrrrrrrrrsp    "  5 *   " ( "  4