ó
P'—^c           @@  sf   d  d l  m Z d  d l Z d  d l m Z d  d l m Z d  d l m Z d e f d „  ƒ  YZ	 d S(   i    (   t   absolute_importN(   t   solo(   t   noop(   t   AppCaset   test_solo_TaskPoolc           B@  s#   e  Z d  „  Z d „  Z d „  Z RS(   c         C@  s   t  j ƒ  } | j ƒ  d  S(   N(   R   t   TaskPoolt   on_start(   t   selft   x(    (    sD   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/concurrency/test_solo.pyt   test_on_start   s    c         C@  s6   t  j ƒ  } | j ƒ  | j t j d i  t t ƒ d  S(   Ni   (   i   i   (   R   R   R   t   on_applyt   operatort   addR   (   R   R   (    (    sD   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/concurrency/test_solo.pyt   test_on_apply   s    
c         C@  s*   t  j ƒ  } | j ƒ  |  j | j ƒ d  S(   N(   R   R   R   t
   assertTruet   info(   R   R   (    (    sD   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/concurrency/test_solo.pyt	   test_info   s    
(   t   __name__t
   __module__R	   R   R   (    (    (    sD   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/concurrency/test_solo.pyR   
   s   		(
   t
   __future__R    R   t   celery.concurrencyR   t   celery.utils.functionalR   t   celery.tests.caseR   R   (    (    (    sD   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/concurrency/test_solo.pyt   <module>   s
   