ó ßüÚ\c@`s‡ddlmZmZmZddlmZddlZddlZddlZddl m Z ddl m Z ddl Z ddlZddlmZddlmZddlZddlmZmZmZdd lmZmZdd lm Z dd lmZmZmZm Z m!Z!m"Z"m#Z#m$Z$dd lm%Z%dd l&m'Z'ddl(m)Z)ddl*m+Z+d„Z,d„Z-ej.j/dddƒd„ƒZ0ej.j/dddƒd„ƒZ1d„Z2d„Z3ej.j/dddƒde+e j4fd„ƒYƒZ5ej.j/dddƒd„ƒZ6d„Z7eƒd„ƒZ8d „Z9d!„Z:ej.j/dddƒd"„ƒZ;d#„Z<d$„Z=d%„Z>d&„Z?ej.j@d'eAeBgƒd(„ƒZCej.j/ejDdLkdd+ƒd,„ƒZEeƒd-„ƒZFd.„ZGd/„ZHd0„ZIej.j@d1dd)gƒd2„ƒZKej.j@d1dd)gƒd3„ƒZLd4„ZMej.j/ejDdMkdd+ƒd5„ƒZNd6„ZOd7„ZPd8„ZQd9„ZRd:„ZSd;„ZTd<„ZUeƒd=„ƒZVd>„ZWd?„ZXd@„ZYdA„ZZdB„Z[ej.j/ej\j]dCƒ ddDƒdE„ƒZ^dFefdG„ƒYZ_dH„Z`dI„ZaejDdNkrƒddKlbTndS(Oi(tprint_functiontdivisiontabsolute_import(tpartialN(tsleep(tLock(tIOLoop(tgen(tClienttWorkertNanny(t LocalClustertnprocesses_nthreads(ttime(tinctgen_testtslowinctassert_cannot_connecttassert_can_connect_locally_4t$assert_can_connect_from_everywhere_4t&assert_can_connect_from_everywhere_4_6tcaptured_logger(tloop(tsync(t TOTAL_MEMORY(t ClusterTestc `sÀtddddtdtddd|ƒ}t|ƒ{}|jtdƒ‰ˆjƒˆj|jj ksst ‚t ‡fd †|j Dƒƒs˜t ‚|j |j ks°t ‚WdQXWdQXdS( Nitscheduler_portit processest silence_logstdashboard_addressRic3`s(|]}|jidˆj6kVqdS(iN(tdatatkey(t.0tw(tx(sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys 1s(R tFalsetNoneRtsubmitRtresultRt schedulerttaskstAssertionErrortanytworkersR(Rtcte((R"sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_simple$s  %cC`s†tddgddd|ƒG}t|ƒ2}tjtƒ}|jd„dƒWdQXWdQXWdQXdt|jƒks‚t‚dS( Ntblocked_handlerst run_functiont n_workersiRcS`s|S(N((R"((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt:ti*sB'run_function' handler has been explicitly disallowed in Scheduler( R Rtpytesttraisest ValueErrortrun_on_schedulertstrtvalueR)(RR,tclienttexc((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt,test_local_cluster_supports_blocked_handlers6s !%ssys.version_info[0] == 2treasons fork issuesc C`sŸtƒ}t|jƒ,}|jttdƒƒ}|j|ƒWdQXtdƒ%}|jƒ|jƒt dƒWdQX|j ƒ}| s•t ‚WdQXdS(Nidstornado.applicationgà?( R Rtscheduler_addresstmapRtrangetgatherRtcloseRtgetvalueR)(tclusterR:tftlog((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_close_twiceAs    s multi-loopcC`s·tddddtdddddtƒ¤}t|jƒdksHt‚td „|jDƒƒsgt‚t|jj ƒE}td „|jDƒƒs›t‚td „|jDƒƒsºt‚WdQXt |ƒWdQXtddddt dddddtƒ·}t|jƒdkst‚td „|jDƒƒs7t‚t|jj ƒX}td „|j ƒj ƒDƒƒstt‚|jƒtd„|jDƒƒst‚WdQXt |ƒWdQXdS(NiRiRtthreads_per_workeriRRcs`s|]}t|tƒVqdS(N(t isinstanceR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys Zscs`s|]}|jdkVqdS(iN(tncores(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys \scs`s|]}t|tƒVqdS(N(RIR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ]scs`s|]}t|tƒVqdS(N(RIR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys iscs`s|]}|dkVqdS(iN((R tv((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys kscs`s|]}t|tƒVqdS(N(RIR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ns(R R#R$tlenR+R)tallRR'taddresstreprtTrueRJtvaluest start_worker(R,R-((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_procsOs: % ( %c C`s¹tdtdtddƒ˜}|jjdƒs6t‚|jdjjdƒsUt‚t|ƒL}t ƒ}|j |ƒ}|j d„|ƒ}|j ƒ|ks©t‚WdQXWdQXdS(s] Test that unserializable data is still fine to transfer over inproc transports. RRRs inproc://icS`s|S(N((R"((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyR2R3N( R R#R$R>t startswithR)R+RNRRtscatterR%R&(RDR:tlockR"ty((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_move_unserializable_datars cC`sÞtddtdtdd ƒ}}|jjdƒs9t‚|jdjjdƒsXt‚t|j jƒ+}|j t dƒj ƒdks‘t‚Wd QXWd QXtddt dtdd ƒ}}|jjd ƒsÖt‚|jdjjd ƒsõt‚t|j jƒ+}|j t dƒj ƒdks.t‚Wd QXWd QXtddtd d dtdd ƒz}|jd ksvt‚|jdjjd ƒs•t‚t|j jƒ+}|j t dƒj ƒdksÎt‚Wd QXWd QXd S(sK Test the transport chosen by LocalCluster depending on arguments. iRRRs inproc://iiiNstcp://RiR"stcp://127.0.0.1:8786(R R#R$R>RTR)R+RNRR'R%RR&RP(R,R-((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_transportsƒs200 R3t LocalTestcB`s-eZeededdƒZidd6ZRS(RRN(t__name__t __module__RR R#R$tClustertkwargs(((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyRZ§sc C`sˆtddddtddd|ƒ^}t|ƒI}t|jƒƒt|jƒks]t‚|jt |ƒksxt‚WdQXWdQXdS(NiRiRRR( R R#R$RRLRJR+R)R>RO(RR,R-((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_Client_with_local­s !'cC`s:td|dtƒ}WdQX|jjdks6t‚dS(NRRtclosed(RR#RDtstatusR)(RR,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_Client_solo·sc c`sÁtjdƒtdtdtddƒV}tjtƒ#}tdtdtddƒV}WdQXd|jjjksxt ‚d|jjjks“t ‚t d„|j Dƒƒs²t ‚|j ƒVdS(NtbokehRRRi”&c3`s4|]*‰t‡fd†dddgDƒƒVqdS(c3`s*|] }|tˆjƒjƒkVqdS(N(R8tmessagetlower(R tword(tmsg(sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys Ést9876trunningsalready in useN(RM(R ((RgsBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys Ès( R4t importorskipRR#twarnst ExceptionRDR'tservicesR)R*tlistRB(tc1tinfotc2((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_duplicate_clients½s "c C`s†td|dtdddtƒG}t|jjƒdksBt‚td„|jjDƒƒsdt‚WdQX|jjdks‚t‚dS(NRRR1iRcs`s|]}t|tƒVqdS(N(RIR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ÔsR`(RR#RLRDR+R)RMRa(RR,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_Client_kwargsÑs$(c C`sptd|dtddƒO}td|dtddƒ+}|jjj|jjjks`t‚WdQXWdQXdS(NRRR(RR#R$RDR'tportR)(RR,RE((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_Client_twiceØscC`s‰ddlm}tdddtddƒK}td„|jDƒƒ|ksSt‚td„|jDƒƒsrt‚WdQXtdtdddtddƒf}td „|jDƒƒ|ksÁt‚td „|jDƒƒsàt‚t |jƒd ksût‚WdQXtd d dddtddƒa}|d dkrGt d |ƒ}nt d |d ƒ}td„|jDƒƒ|kst‚WdQXtd|d dddtddƒ"}t |jƒd ksÈt‚WdQXtd |d dddtddƒ&}td„|jDƒƒst‚WdQXtdd d ddddtddƒA}t |jƒdks`t‚td„|jDƒƒst‚WdQXdS(Ni(t_ncoresRRRcs`s|]}|jVqdS(N(RJ(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys åscs`s|]}t|tƒVqdS(N(RIR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys æsRcs`s|]}|jVqdS(N(RJ(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ëscs`s|]}t|tƒVqdS(N(RIR (R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ìsiR1ics`s|]}|jVqdS(N(RJ(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ÷sRHcs`s|]}|jdkVqdS(iN(RJ(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys sics`s|]}|jdkVqdS(iN(RJ(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys s( tdistributed.workerRvR R#R$tsumR+R)RMRLtmax(RvR,texpected_total_threads((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_defaultsÞsT%%%!+  !  % c C`sftdddddtddddƒ9}g|jD]}|j^q4dgdks\t‚WdQXdS( NR1iRiRRt memory_limitiô(R R#R$R+R|R)(R,R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_worker_paramss c C`swtdddddtdtddddƒD}|jd}t|jƒtksXt‚|jdksmt‚WdQXdS( NR1iRiRRRR|( R R#R$R+ttypeRtdictR)R|(R,R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_memory_limit_nones  cC`s`tddddtddƒ}|jj}|jƒtdd|dtddƒ}|jƒdS(NiRiRR(R R#R$R'RtRB(R,RtRq((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_cleanup,s   c C`sRtddddtddƒ}WdQXtddddtddƒ}WdQXdS(NiRi!RR(R R#R$(R,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_repeated6sRc C`stjdƒtjdƒ}tdddddtd|d|d dƒ›}|jjdj}d |}tƒ}xItr½|j |ƒ}|j r—Pntƒ|d ks°t ‚t d ƒquW|j d |ƒ}|j sàt ‚WdQXtj |jƒ|j |ddƒWdQXdS(NRctrequestsR1iRRRRRshttp://127.0.0.1:%d/status/ig{®Gáz„?shttp://localhost:%d/status/ttimeoutgš™™™™™É?(R4RjR R#R'RmRtR RPtgettokR)RR5tRequestException(RRRƒR,t bokeh_portturltstarttresponse((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_bokehAs.      iitUnknowncC`s:td|ƒ%}t|jƒƒdks0t‚WdQXdS(NRi(RRLRJR)(RR,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_blocks_until_full^scc`stjƒ}tddddtdtddd|dtƒV}t|dtƒV}|j s`t‚|j dƒVt |jƒdks‰t‚t |j j ƒdks§t‚|jdj }|j|gƒVt |jƒd ksãt‚||j j ksût‚|jƒV|jƒVdS( NiRRRRRt asynchronousii(RtcurrentR R#R$RPRR+R)tscale_upRLR'RJRNt scale_downRB(RRDR,taddr((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_scale_up_and_downds(   cC`syd}tjtjdd|gdtjƒ}|jƒ}y| sIt‚Wn(tk rttdƒt|ƒ‚nXdS(Nsºif 1: from time import sleep from distributed import LocalCluster with LocalCluster(1, dashboard_address=None, scheduler_port=0): sleep(1.5) s-Wis-ctstderrs=== Cluster stdout / stderr ===(t subprocesst check_outputtsyst executabletSTDOUTtdecodeR)tprint(tcodetout((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_silent_startup‚s!    c C`sGtddddtddd|ƒ}t|t|jjƒWdQXdS(NiRRRR(R R#R$RRR'Rt(RR,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_only_local_access—s!c C`sMtddddtddddd|ƒ}t|t|jjƒWdQXdS(NiRRRtipR3R(R R#R$RRR'Rt(RR,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_remote_accessžs R1c C`s_td|dddtdtddd|ƒ,}td„|jDƒƒtksUt‚WdQXdS( NR1RiRRRRcs`s|]}|jVqdS(N(R|(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ´s(R R#R$RxR+RR)(RR1RD((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_memoryªs c C`std|dddtdtddd|ƒ]}t|jd|ƒ?}|jƒ}td„|d jƒDƒƒt ks€t ‚WdQXWdQXdS( NR1RiRRRRcs`s|]}|dVqdS(R|N((R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys ÄsR+( R RPR#R$RR>tscheduler_infoRxRQRR)(RR1RDR,Rp((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_memory_nanny·s  cC`sMtjtjƒ5tdddtddddd|ƒ}WdQXWdQXdS(NRiRt death_timeoutg»½×Ùß|Û=RR(R4R5Rt TimeoutErrorR R#R$(RRD((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_death_timeout_raisesÈs cC`sztjdƒtdddddtd|dddiid d 6d6ƒ,}|jjd}|jd kspt‚WdQXdS( NRcR1iRRRRtservice_kwargss/footprefix(R4RjR R#R'RmRªR)(RR,tbs((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_bokeh_kwargsÔs cC`s¯td|dtƒ”}|jj|ks0t‚x/|jjjƒD]}|j|ksCt‚qCWx@|jD]5}x,|jjƒD]}|j|ks‚t‚q‚WqlWWdQXdS(NRR( R R#R'RR)tperiodic_callbacksRQtio_loopR+(RRDtpctworker((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_io_loop_periodic_callbacksäscC`sStddtddƒ5}|jjjs0t‚|jdjjsIt‚WdQXdS(s< Workers and scheduler have logs even when silenced iRRiN(R R#R$R't_deque_handlertdequeR)R+(R,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_loggingîsc C`sttjdƒ}tdddddtd|dtdtƒ2}|jƒ|j}t||jƒsjt‚WdQXdS( Nt ipywidgetsR1iRRRRR( R4RjR R#t_ipython_display_t_cached_widgetRItWidgetR)(RRµRDtbox((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_ipywidgets÷s   c C`s+tdddtd|dtdtddƒø}|jj sCt‚|jdƒtƒ}xQt|jjƒdkr¬td ƒtƒ|d ks\tt|jjƒƒ‚q\Wtd ƒ|jd ƒtƒ}xQt|jjƒd kr td ƒtƒ|d ksÐtt|jjƒƒ‚qÐWWd QXd S(s; Directly calling scale both up and down works as expected RiRRRRR1ig{®Gáz„?igš™™™™™É?iN( R R#R'R+R)tscaleR RLR(RRDRŠ((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_scales(    /    c C`s!tdddtd|dtdtddƒî}|jddd d d d ƒ|jjdksdt‚|jjd ks|t‚tj|jƒ}|jdd d d d d ƒ|jjd ksÂt‚t j ƒt ƒ}x?t |j jƒd krtdƒt ƒ|dksØt‚qØWWdQXdS(NRiRRRRR1tminimumtmaximumitintervalt10msig{®Gáz„?i(R R#tadaptt _adaptiveR½R)R¾tweakreftreftgctcollectR RLR'R+R(RRDRÄRŠ((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt test_adapt"s&   c C`sdtdddtd|dtdtddƒ1}td ƒ|jd dd d d dƒtƒ}x<|jjsw|jrtd ƒtƒ|dksbt‚qbW|j s®t‚t|ƒž}|j t t dƒdd ƒ}tdƒ|j j ƒtdƒ|jdƒtƒ}x?t|jjƒdkrStd ƒtƒ|dkst‚qWWdQXWdQXdS(s- We can revert from adaptive, back to manual RiRRRRR1igš™™™™™¹?R½R¾iR¿RÀiiètdelaygš™™™™™É?iN(R R#RRÁR R'R+R)RR?RR@RÂtstopR»RL(RRDRŠR:tfutures((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_adapt_then_manualAs2          cC`s¼ddlm}|ƒ}tdddddtd|dtd d d |ƒj}t|t|jjd |jd ƒddddƒt|t dd|jjd |jd ƒdt ƒWdQXdS(Ni(ttls_only_securityR1RiR"RtsecurityRR¡s tls://0.0.0.0Rtconnection_argsR:tprotocolttlsR„iR“stcp://127.0.0.1:%dtexception_class( tdistributed.utils_testRÌR R#RRR'Rttget_connection_argsRt RuntimeError(RRÌRÍR,((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_local_tlses0   cc`sJdtfd„ƒY}tjƒ}|ddddtdtddd|d tƒV}t|d tƒV}|j svt‚|j d ƒVt ƒ}xCt |j jƒd krÒt jd ƒVt ƒ|d kst‚qW|j d ƒVt ƒ}xCt |j jƒd kr/t jd ƒVt ƒ|d ksít‚qíW|jƒV|jƒVdS(Nt MyClustercB`seZd„ZRS(c_`sdS(N((tselftargsR^((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyR’ˆs(R[R\R’(((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyRÖ‡siRRRRRRig{®Gáz„?ii(R RRR#R$RPRR+R)R»R RLR'RRRB(RÖRRDR,RŠ((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_scale_retires_workers…s0     cC`s*ddlm}|ƒ}tdddddtd|d td d d |ƒØ}t|jjd |d|ƒ±}t|j|jdjƒt |j ƒd ƒ}|j t dƒj ƒdksÄt‚|jƒt |j ƒd ƒ}|j t dƒj ƒdkst‚||kst‚WdQXWdQXdS(Ni(RÌR1iRiR"RRÍRR¡s tls://0.0.0.0RR+ii(RÒRÌR R#RR'RNRœR+tsetR¤R%RR&R)trestart(RRÌRÍR,R:tworkers_beforet workers_after((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_local_tls_restart«s&  !$ $cC`s tdƒdkst‚tdƒdks0t‚tdƒdksHt‚tdƒdks`t‚tdƒddfks~t‚td ƒdks–t‚td ƒddfks´t‚td ƒdksÌt‚td ƒddfksêt‚tdƒddfkst‚dS(Niiiiii iiiii i(i iPi(ii(ii(ii(ii(ii(ii(ii(ii(ii(ii(ii(i i(i i(ii(R R)(((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt%test_default_process_thread_breakdownÂsc `s\tddddtdtddd|ƒ,‰tj‡fd†ƒ}ˆj|ƒWdQXdS( NiRiRRRRc`sˆjst‚dS(N(RR)((RD(sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyt_Ùs(R R#R$Rt coroutineR(RRà((RDsBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_asynchronous_propertyÏs cC`sCtddd|dtƒ"}|jjjdƒs9t‚WdQXdS(NRÏs inproc://RR(R R#R'RNRTR)(RRD((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_protocol_inprocàsc C`sItddd|dddtƒ"}|jjjdƒs?t‚WdQXdS(NRÏttcpRR1iRstcp://(R R#R'RNRTR)(RRD((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_protocol_tcpåstlinuxs Need 127.0.0.2 to mean localhostc C`sItddd|dddtƒ"}|jjjdƒs?t‚WdQXdS(NR¡stcp://127.0.0.2RR1iR(R R#R'RNRTR)(RRD((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_protocol_ipìstMyWorkercB`seZRS((R[R\(((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyRèösc C`sYtddd|dtdtddddƒ&}td „|jDƒƒsOt‚WdQXdS( NR1iRt worker_classRRiRcs`s|]}t|tƒVqdS(N(RIRè(R R!((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys s(R RèR#R$RMR+R)(RRD((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_worker_class_workerús c `sodtfd„ƒY‰tddd|dˆddd dƒ,}t‡fd †|jDƒƒset‚WdQXdS( NtMyNannycB`seZRS((R[R\(((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyRësR1iRRéRiRc3`s|]}t|ˆƒVqdS(N(RI(R R!(Rë(sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pys s(R R R$RMR+R)(RRD((RësBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyttest_worker_class_nannys i(t*(ii(ii(ii(ct __future__RRRt functoolsRRÅR–R˜R Rt threadingRtunittestRÃttornado.ioloopRttornadoRR4t distributedRR R tdistributed.deploy.localR R tdistributed.metricsRÒRRRRRRRRRtdistributed.utilsRRwRtdistributed.deploy.utils_testRR.R<tmarktskipifRGRSRXRYtTestCaseRZR_RbRrRsRuR{R}R€RR‚t parametrizeRPR#RŒt version_infoRŽR”RŸR R¢R$R£R¥R¨R¬R±R´RºR¼RÇRËRÕRÙRÞRßRâRãRåtplatformRTRçRèRêRìt(distributed.deploy.tests.py3_test_deploy(((sBlib/python2.7/site-packages/distributed/deploy/tests/test_local.pyts†      :   !!#  $!   !5  $*   $ $ *    $ &     %