ó
P'—^c           @@  s[   d  Z  d d l m Z d d l Z d d l m Z m Z d g Z d e f d „  ƒ  YZ d S(   sd   
    celery.concurrency.solo
    ~~~~~~~~~~~~~~~~~~~~~~~

    Single-threaded pool implementation.

i    (   t   absolute_importNi   (   t   BasePoolt   apply_targett   TaskPoolc           B@  s    e  Z d  Z d „  Z d „  Z RS(   s(   Solo task pool (blocking, inline, fast).c         O@  s&   t  t |  ƒ j | | Ž  t |  _ d  S(   N(   t   superR   t   __init__R   t   on_apply(   t   selft   argst   kwargs(    (    s9   /tmp/pip-unpacked-wheel-gV1wwp/celery/concurrency/solo.pyR      s    c         C@  s0   i d d 6t  j ƒ  g d 6d  d 6t d 6d d 6S(   Ni   s   max-concurrencyt	   processess   max-tasks-per-childs   put-guarded-by-semaphoret   timeouts(    (   t   ost   getpidt   Nonet   True(   R   (    (    s9   /tmp/pip-unpacked-wheel-gV1wwp/celery/concurrency/solo.pyt	   _get_info   s
    
(   t   __name__t
   __module__t   __doc__R   R   (    (    (    s9   /tmp/pip-unpacked-wheel-gV1wwp/celery/concurrency/solo.pyR      s   	(	   R   t
   __future__R    R   t   baseR   R   t   __all__R   (    (    (    s9   /tmp/pip-unpacked-wheel-gV1wwp/celery/concurrency/solo.pyt   <module>   s
   	