σ ¦–Υ\c@`s€ddlmZmZmZddlZddlZddlmZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZddlmZmZmZmZddlmZd„Zd„Zd „Zd „Zd „Zd „Zd efd„ƒYZd„Zd„Z d„Z!d„Z"d„Z#e j$j%de j e gƒd„ƒZ&e j$j'ej(dkddƒe j$j'ej)j*dkddƒd„ƒƒZ+e j$j'ej(dkddƒe j$j'ej)j*dkddƒd„ƒƒZ,e j$j'ej(dko+ej)j*dkddƒd„ƒZ-e j$j'ej(dkogej)j*dkddƒd„ƒZ.dS( i(tabsolute_importtdivisiontprint_functionN(tadd(tcomputetdelayed(tgett_dumpst get_contexttremote_exception(tinccC`sXd„}d„}t|ƒ}d|ks0t‚d|ksBt‚d|ksTt‚dS(s> Unrelated globals should not be included in serialized bytes cS`stj|gƒS(N(tnptarray(ta((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytunrelated_functionscS`s||S(N((R tb((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytmy_small_functionsRRtnumpyN(RtAssertionError(RRR((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_pickle_globalss    cC`stdƒ‚dS(Nt12345(t ValueError(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytbad"scC`shitfd6}yt|dƒWn@tk rc}t|tƒsHt‚dt|ƒksdt‚nXdS(NtxR(RRt Exceptiont isinstanceRRtstr(tdskte((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_errors_propagate&s cC`s©tdƒ}t|dƒ}t|dƒ}t|ƒt|ƒksHt‚t|tƒs]t‚dt|ƒksut‚dt|ƒkst‚dt|ƒks₯t‚dS(Nthellostraceback-bodyt Traceback(t TypeErrorR ttypeRRR(RR R((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_remote_exception0s cC`sd„S(NcS`s|dS(Ni((R((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt=t((((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytmake_bad_result<scC`sVitfd6}yt|dƒWn.tk rQ}t|ƒjdksRt‚nXdS(NRt PicklingErrortAttributeError(R&R'(R%RRR!t__name__R(RR((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt(test_unpicklable_results_generate_errors@s tNotUnpickleablecB`seZd„Zd„ZRS(cC`sdS(N(((tself((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt __getstate__LscC`stdƒ‚dS(NsCan't unpickle me(R(R+tstate((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt __setstate__Os(R(t __module__R,R.(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyR*Ks cC`s»tƒ}d„}i||fd6}yt|dƒWn(tk r`}t|tƒsat‚nXi|dfd6|d6}yt|dƒWn(tk rΆ}t|tƒs·t‚nXdS(NcS`sdS(Ni((R ((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytfooVsRR (R*RRRRR(R R0RR((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt%test_unpicklable_args_generate_errorsSs   cC`s|tjƒ}tjjd|ƒUtitdfd6dƒdksJt‚titdfd6dƒdksrt‚WdQXdS(NtpooliRi(tmultiprocessingtPooltdasktconfigtsetRR R(R2((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_reuse_poolis (c C`s^tjjdtjdtjƒ7tidd6tddfd6dƒdksTt‚WdQXdS(Nt func_dumpst func_loadsiRityi( R5R6R7tpickletdumpstloadsRRR(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_dumps_loadsps"cC`sOidd6tdfd6tddfd6}t|ddgƒdksKt‚dS( NiRR;i tzii (ii (R RRR(td((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt&test_fuse_doesnt_clobber_intermediatesus*c `sŽddlm}idd6tdfd6tddfd6}g‰|d‡fd †ƒt|dd tƒWdQXtˆƒd ksŠt‚dS( Ni(tCallbackiRR;i R@tpretaskc`s ˆj|ƒS(N(tappend(tkeytargs(tkeys(s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyR#~R$toptimize_graphi(tdask.callbacksRCR RRtFalsetlenR(RCRA((RHs>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_optimize_graph_falsezs *trandomc `sŠ‡fd†}d}tjjddƒ<tgt|ƒD]}t|dtƒƒ^q;ƒ\}WdQXtt|ƒƒ|ks†t‚dS(Nc`s t‡fd†tdƒDƒƒS(Nc3`s!|]}ˆjddƒVqdS(ii'N(trandint(t.0ti(RN(s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pys †si(ttupletrange((RN(s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytf…si t schedulert processestpure( R5R6R7RRSRRKRLR(RNRTtNRQtresults((RNs>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_random_seedsƒs =twin32treasons*Windows doesn't support different contextsis+Python 2 doesn't support different contextscC`s~d„}ddl}d|jdlib/python2.7/site-packages/dask/tests/test_multiprocessing.pytcheck_for_pytestœs iNiR]tspawnsmultiprocessing.contextR(R^R_R5R6R7RR(R`R^tresult((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt&test_custom_context_used_python3_posixs   cC`sžtƒtjdƒkst‚tjjidd6ƒ#tƒtjdƒksVt‚WdQXtjjidd6ƒ#tƒtjdƒks”t‚WdQXdS(sq get_context() respects configuration. If default context is changed this test will need to change too. t forkserversmultiprocessing.contextNRa(RR3tNoneRR5R6R7(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt$test_get_context_using_python3_posixͺs $s*Python 3 POSIX supports different contextsc C`sŠtitdfd6dƒdks(t‚tjtƒMtjjidd6ƒ-titdfd6dƒdkszt‚WdQXWdQXdS(sΆ On Python 2/Windows, setting 'multiprocessing.context' doesn't explode. Presumption is it's not used since unsupported, but mostly we care about not breaking anything. iRiRdsmultiprocessing.contextN( RR Rtpytesttwarnst UserWarningR5R6R7(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyt%test_custom_context_ignored_elsewhereΊs(c C`sdtƒtkst‚tjtƒ:tjjidd6ƒtƒtksTt‚WdQXWdQXdS(s@ On Python 2/Windows, get_context() always returns same context.Rdsmultiprocessing.contextN( RR3RRgRhRiR5R6R7(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pyttest_get_context_always_defaultΘs(/t __future__RRRR^R3toperatorRR<RNRR RgR5RRtdask.multiprocessingRRRR tdask.utils_testR RRRR"R%R)tobjectR*R1R8R?RBRMtmarkt parametrizeRZtskipiftplatformt version_infotmajorRcRfRjRk(((s>lib/python2.7/site-packages/dask/tests/test_multiprocessing.pytsH       "         '  * *