ó
ßüÚ\c           @   sÌ   d  d l  Z  d  d l Z d  d l m Z d  d l m Z d  d l m Z m Z d  d l	 m
 Z
 e j ƒ  e j d d e d e ƒe j d	 d e d e ƒd
 „  ƒ ƒ ƒ Z d „  Z e d k rÈ e ƒ  n  d S(   iÿÿÿÿN(   t   gen(   t   IOLoop(   t   check_python_3t   install_signal_handlers(   t   _submitt   remote_client_addresst   typet   requiredt   filepathc            s2   t  j ‡  ‡ f d †  ƒ } t j ƒ  j | ƒ d  S(   Nc          3   sX   t  ˆ ˆ  ƒ V\ }  } |  r5 t j j t |  ƒ ƒ n  | rT t j j t | ƒ ƒ n  d  S(   N(   R   t   syst   stdoutt   writet   strt   stderr(   R
   R   (   R   R   (    s:   lib/python2.7/site-packages/distributed/cli/dask_submit.pyt   f   s
    (   R    t	   coroutineR   t   instancet   run_sync(   R   R   R   (    (   R   R   s:   lib/python2.7/site-packages/distributed/cli/dask_submit.pyt   main	   s    c           C   s   t  ƒ  t ƒ  t ƒ  d  S(   N(   R   R   R   (    (    (    s:   lib/python2.7/site-packages/distributed/cli/dask_submit.pyt   go   s    t   __main__(   R	   t   clickt   tornadoR    t   tornado.ioloopR   t   distributed.cli.utilsR   R   t   distributed.submitR   t   commandt   argumentR   t   TrueR   R   t   __name__(    (    (    s:   lib/python2.7/site-packages/distributed/cli/dask_submit.pyt   <module>   s   	*	