\c@s*ddlmZdefdYZdS(i(tClientt ClusterTestcBsSeZdZiZdZdZdZdZdZ dZ dZ RS(cCs7|jddd|j|_t|jj|_dS(Nitscheduler_porti(tClustertkwargstclusterRtscheduler_addresstclient(tself((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pytsetUpscCs|jj|jjdS(N(RtcloseR(R((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyttearDown s cCs%t|jjdks!tdS(Ni(tlenRtncorestAssertionError(R((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyt test_coresscCs4|jjdd}|jdks0tdS(NcSs|dS(Ni((tx((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyttii(RtsubmittresultR(Rtfuture((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyt test_submitscCs|jj}|jjdd}|jj}t|dt|ksUttd|jDswt|jj||jj}||kstdS(NR iicss|]}|dkVqdS(iN((t.0tv((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pys s( RR Rt start_workerR Rtanytvaluest stop_worker(Rtatwtbtc((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyttest_start_workers""c CsF|j|j.}t|}|js6tWdQXWdQXdS(N(RRRR R(RR te((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyttest_context_manager$scCs&|jddd|jWdQXdS(NiR(RR(R((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyttest_no_workers)sN( t__name__t __module__tNoneRRR R RRR!R#R$(((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyRs     N(RRtobjectR(((s<lib/python2.7/site-packages/distributed/deploy/utils_test.pyts