ķ
P'^c           @@  s­   d  d l  m Z d  d l m Z d  d l m Z m Z m Z d  d l m	 Z	 m
 Z
 m Z m Z e s} d e	 f d     YZ n  d e	 f d     YZ d	 e	 f d
     YZ d S(   i    (   t   absolute_import(   t
   IS_WINDOWS(   t   detacht   detached_celerydt   main(   t   AppCaset   Mockt   override_stdoutst   patcht   test_detachedc           B@  sA   e  Z e d   e d  e d  e d  d       Z RS(   s"   celery.bin.celeryd_detach.detacheds   os.execvs    celery.bin.celeryd_detach.loggers.   celery.app.log.Logging.setup_logging_subsystemc         C@  s  t    } | _ t    | _ t    | _ t d d d d g d d d d d	 d
 | j d d d  d  d  d  t d t | j d d d d d g  t d  | _	 t d d d d g d d d d d	 d
 d |  j
 } | j j   |  j | j j  | j d d d	 d
 |  j | d  d  S(   Ns   /bin/boot   at   bt   ct   logfiles   /var/logt   pidfiles   /var/pidt   hostnames   foo@example.comt   after_forkerst   foot   appt   ERRORi   (   R   t   return_valuet	   __enter__t   __exit__R   t   assert_called_witht   Nonet   Falset	   Exceptiont   side_effectR   t
   assertTruet   criticalt   calledt   assertEqual(   t   selft
   setup_logst   loggert   execvt   detachedt   contextt   r(    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyt
   test_execs   s&    (   t   __name__t
   __module__R   R'   (    (    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyR	      s   			t   test_PartialOptionParserc           B@  s   e  Z d    Z RS(   c         C@  sn  t  |  j  } | j d  } | j d d d d d d d d	 g  \ } } |  j | j d
  |  j | d d g  |  j | j d d d d	 g  t    |  j t	   | j d g  Wd  QXd | j
 d  _ |  j t	   | j d g  Wd  QX|  j t	   | j d g  Wd  QXWd  QX| j
 d  j d k sEt  | j d d g  d | j
 d  _ d  S(   Nt   celeryd_detachs   --logfile=foos   --fakes   --enableR
   R   s   -c1s   -dt   2R   s	   --logfilei   s   --logfile=as
   --fake=abci   (   R   R   t   Parsert
   parse_argsR   R   t	   leftoversR   t   assertRaisest
   SystemExitt
   get_optiont   nargst   AssertionError(   R    t   xt   pt   optionst   values(    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyt   test_parser/   s$    
(   R(   R)   R9   (    (    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyR*   -   s   t   test_Commandc           B@  sb   e  Z d  d d d d d d g Z d   Z e d  e d	  d
     Z e d  d    Z RS(   s   --autoscale=10,2s   -ct   1s   --logfile=/var/logs   -lDEBUGs   --s   .disable_rate_limits=1c         C@  sy   t  d |  j  } | j d |  j  \ } } } |  j | j d  |  j | d d d d d d	 g  | j d g   d  S(
   NR   t   cds   /var/logs   --autoscale=10,2s   -cR;   s   -lDEBUGs   --logfile=/var/logs   --pidfile=celeryd.pid(   R   R   t   parse_optionst   argvR   R   (   R    R5   t   ot   vt   l(    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyt   test_parse_optionsK   s    
s   sys.exits    celery.bin.celeryd_detach.detachc         C@  sĒ   t  d |  j  } | j |  j  |  j | j  | j d | j d d  d d  d d  d t	 d d d	 d
 d d  d d  d d  d | j
 d d d d d d d g d |  j  d  S(   NR   t   patht   uidt   gidt   umaskt   fakeR   s   /var/logR   s   celeryd.pidt   working_directoryt
   executableR   R>   s   -cR;   s   -lDEBUGs   --logfile=/var/logs   --pidfile=celeryd.pids   --s   .disable_rate_limits=1(   R   R   t   execute_from_commandlineR>   R   R   R   t
   execv_pathR   R   t
   execv_argv(   R    R   t   exitR5   (    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyt   test_execute_from_commandlineT   s    		s*   celery.bin.celeryd_detach.detached_celerydc         C@  s.   t    } | _ t |  j  | j j   d  S(   N(   R   R   R   R   RJ   R   (   R    t   commandR   (    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyt	   test_mainf   s    (   R(   R)   R>   RB   R   RN   RP   (    (    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyR:   F   s   				N(   t
   __future__R    t   celery.platformsR   t   celery.bin.celeryd_detachR   R   R   t   celery.tests.caseR   R   R   R   R	   R*   R:   (    (    (    sF   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_celeryd_detach.pyt   <module>   s   "