ó ßüÚ\c@`sŒddlmZmZmZddlmZddlZddlmZm Z ddl m Z m Z m Z eded„ƒZd „ZdS( i(tprint_functiontdivisiontabsolute_import(tcontextmanagerNi(tsecedetrejoin(t thread_statet get_clientt get_workericc`s]tƒ}td|ƒ}|rDtƒ|jj|jtjdƒn|V|rYtƒndS(s¯ Get client for this thread This context manager is intended to be called within functions that we run on workers. When run as a context manager it delivers a client ``Client`` object that can submit other tasks directly from that worker. Parameters ---------- timeout: Number Timeout after which to err separate_thread: bool, optional Whether to run this function outside of the normal thread pool defaults to True Examples -------- >>> def func(x): ... with worker_client() as c: # connect from worker back to scheduler ... a = c.submit(inc, x) # this task can submit more tasks ... b = c.submit(dec, x) ... result = c.gather([a, b]) # and gather results ... return result >>> future = client.submit(func, 1) # submit func(1) on cluster See Also -------- get_worker get_client secede ttimeouts long-runningN( RRRtloopt add_callbackt transitionRtkeyR(R tseparate_threadtworkertclient((s8lib/python2.7/site-packages/distributed/worker_client.pyt worker_client s! cO`stjdƒt||ŽS(Ns'local_client has moved to worker_client(twarningstwarnR(targstkwargs((s8lib/python2.7/site-packages/distributed/worker_client.pyt local_client7s (t __future__RRRt contextlibRRtthreadpoolexecutorRRRRRRtTrueRR(((s8lib/python2.7/site-packages/distributed/worker_client.pyts ,