ó
ßüÚ\c           @` sN   d  d l  m Z m Z m Z d  d l m Z m Z m Z d „  Z d „  Z	 d S(   i    (   t   print_functiont   divisiont   absolute_import(   t   gzip_compresst   gzip_decompresst   finalizec          C` s4   d }  t  |  ƒ } t | ƒ } |  | k s0 t ‚ d  S(   Ns   Hello, world!(   R   R   t   AssertionError(   t   bt   ct   d(    (    sC   lib/python2.7/site-packages/distributed/tests/test_compatibility.pyt	   test_gzip   s    c          ` s  d t  f d „  ƒ  Y}  g  ‰  ‡  f d †  } |  ƒ  } t | | d ƒ } | | j ƒ  k s^ t ‚ t | _ | | j ƒ  k s t ‚ ˆ  sŒ t ‚ ~ ˆ  j ƒ  d k s§ t ‚ |  ƒ  } t | | d ƒ } | j sÑ t ‚ | ƒ  | j sè t ‚ ˆ  j ƒ  d k s t ‚ ~ ˆ  st ‚ d  S(   Nt   Cc           B` s   e  Z RS(    (   t   __name__t
   __module__(    (    (    sC   lib/python2.7/site-packages/distributed/tests/test_compatibility.pyR      s   c         ` s   ˆ  j  |  ƒ d  S(   N(   t   append(   t   value(   t   l(    sC   lib/python2.7/site-packages/distributed/tests/test_compatibility.pyt   cb   s    i   i   (   t   objectR   t   _select_for_exitR   t   Falset   atexitt   popt   alive(   R   R   t   ot   ft   fin(    (   R   sC   lib/python2.7/site-packages/distributed/tests/test_compatibility.pyt   test_finalize   s&    			N(
   t
   __future__R    R   R   t   distributed.compatibilityR   R   R   R
   R   (    (    (    sC   lib/python2.7/site-packages/distributed/tests/test_compatibility.pyt   <module>   s   	