ó ßüÚ\c@s<ddlmZddlZddlmZddlmZddlmZddl m Z ddl m Z m Z mZddlmZdd lmZmZdd lmZejZejƒZeƒZejƒejd d ed dddƒejdd ed dddƒejdd ed dddƒejdd dddƒejdd dd eddƒejdd e ddƒejdd e ddƒejd d ed d!dd"ƒejd#d ed d$dd%ƒejd&d ed ddd'ƒd(„ƒƒƒƒƒƒƒƒƒƒƒZ!d)„Z"e#d*kr8e"ƒndS(+iÿÿÿÿ(tpartialN(tMPI(tIOLoop(tgen(twarn(t SchedulertNannytWorker(t BokehWorker(tcheck_python_3turi_from_host_port(tget_ip_interfaces--scheduler-filettypetdefaultsscheduler.jsonthelps0Filename to JSON encoded scheduler information. s --interfaces&Network interface like 'eth0' or 'ib0's --nthreadsisNumber of threads per worker.s--memory-limittautosxNumber of bytes before spilling data to disk. This can be an integer (nbytes) float (fraction of total memory) or 'auto's--local-directorytsDirectory to place worker filess--scheduler/--no-schedulers^Whether or not to include a scheduler. Use --no-scheduler to increase an existing dask clusters--nanny/--no-nannys-Start workers in nanny process for managements --bokeh-portiS"s!Bokeh port for visual diagnosticss--bokeh-worker-portiU"s*Worker's Bokeh port for visual diagnosticss--bokeh-prefixsPrefix for the bokeh appc s°|rt|ƒ} nd} tdkrÝ|rÝyddlm} Wntk rZi} n Xit| d|ƒd|f6} td|dtd| ƒ}t | dd ƒ‰|j ˆƒztj ƒtj ƒWd|j ƒXnÏ|rét nt} | d|dtd |r tndd |d |ditd| f6d |ƒ‰t | ddƒ‰tj‡‡fd†ƒ}ztj|ƒtj ƒWdXtj‡fd†ƒ}tj|ƒdS(Niiÿÿÿÿ(tBokehSchedulertprefixtbokehtscheduler_filetlooptservicesiR"tnametncorest local_dirt memory_limitc3s6ˆjˆƒVx!ˆjdkr1tjdƒVqWdS(Ntclosedgš™™™™™É?(t_starttstatusRtsleep((taddrtworker(s7lib/python2.7/site-packages/distributed/cli/dask_mpi.pytrunrsc3sˆjddƒVdS(Nttimeouti(t_close((R (s7lib/python2.7/site-packages/distributed/cli/dask_mpi.pytclose~s(R tNonetranktdistributed.bokeh.schedulerRt ImportErrorRRRR tstartR$tstopRRRRt coroutinetrun_sync(Rt interfacetnthreadstlocal_directoryRt schedulert bokeh_portt bokeh_prefixtnannytbokeh_worker_portthostRRtWR!R$((RR s7lib/python2.7/site-packages/distributed/cli/dask_mpi.pytmainsF9      cCstƒtdƒtƒdS(Ns³The dask-mpi command line utility in the `distributed` package is deprecated. Please install the `dask-mpi` package instead. More information is available at https://mpi.dask.org(R RR7(((s7lib/python2.7/site-packages/distributed/cli/dask_mpi.pytgo…st__main__($t functoolsRtclicktmpi4pyRttornado.ioloopRttornadoRtwarningsRt distributedRRRtdistributed.bokeh.workerRtdistributed.cli.utilsR R tdistributed.utilsR t COMM_WORLDtcommtGet_rankR&RtcommandtoptiontstrR%tinttTrueR7R8t__name__(((s7lib/python2.7/site-packages/distributed/cli/dask_mpi.pyts\     HE