ó
ßüÚ\c           @` s˜   d  d l  m Z m Z m Z d  d l Z d  d l m Z d  d l m Z d  d l	 m
 Z
 m Z d „  Z e j j d d ƒ e d	 e ƒ d
 „  ƒ ƒ Z d S(   i    (   t   print_functiont   divisiont   absolute_importN(   t   rpc(   t   gen_cluster(   t	   pack_datat   gather_from_workersc          C` s    i d d 6}  t  d |  ƒ d k s( t ‚ t  i d d 6d d 6|  ƒ i d d 6d d 6k s_ t ‚ t  i d g d 6d d 6|  ƒ i d g d 6d d 6k sœ t ‚ d  S(   Ni   t   xt   yt   at   b(   R   R   (   i   R   (   R   t   AssertionError(   t   data(    (    s@   lib/python2.7/site-packages/distributed/tests/test_utils_comm.pyt   test_pack_data
   s    7t   reasons%   rpc now needs to be a connection poolt   clientc         c` sŽ   |  j  i d d 6d | j ƒV} t i | j g d 6| j g d 6d t ƒV\ } } } | i d d 6k so t ‚ t | ƒ d g k sŠ t ‚ d  S(   Ni   R   t   workersR   R   (   t   scattert   addressR   R   R   t   list(   t   ct   sR	   R
   R   R   t   missingt   bad_workers(    (    s@   lib/python2.7/site-packages/distributed/tests/test_utils_comm.pyt#   test_gather_from_workers_permissive   s
     3(   t
   __future__R    R   R   t   pytestt   distributed.coreR   t   distributed.utils_testR   t   distributed.utils_commR   R   R   t   markt   xfailt   TrueR   (    (    (    s@   lib/python2.7/site-packages/distributed/tests/test_utils_comm.pyt   <module>   s   	