
P'^c           @@  s   d  d l  m Z d  d l m Z d  d l m Z m Z m Z m Z d e	 f d     YZ
 d	 d  Z d
 e _ d e f d     YZ d	 S(   i    (   t   absolute_import(   t   events(   t   AppCaset   SkipTestt   patcht
   _old_patcht   MockCommandc           B@  s   e  Z g  Z d    Z RS(   c         K@  s   |  j  j t  d  S(   N(   t   executedt   appendt   True(   t   selft   kwargs(    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   execute_from_commandline   s    (   t   __name__t
   __module__R   R   (    (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyR      s   c         C@  s   |  | f t  _ d  S(   N(   t	   proctitlet   last(   t   progt   info(    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyR      s    t   test_eventsc           B@  s   e  Z d    Z e d d d    e d d e  d     Z d   Z e d d	 d
    e d d e  d     Z e d  e d  d     Z	 d   Z
 e d d e  d    Z RS(   c         C@  s   t  j  d |  j  |  _ d  S(   Nt   app(   R   R   t   ev(   R
   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   setup   s    s   celery.events.dumpert   evdumpc          K@  s   d S(   Ns   me dumper, you?(    (   t   kw(    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   <lambda>   t    s   celery.bin.eventst   set_process_titlec         C@  s:   |  j  |  j j d t  d  |  j d t j d  d  S(   Nt   dumps   me dumper, you?s   celery events:dumpi    (   t   assertEqualR   t   runR	   t   assertInR   R   (   R
   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   test_run_dump   s    c         @  sm   y d d  l  } Wn t k
 r/ t d   n Xt d d d    t d d t    f d     } |   S(	   Ni    s   curses monitor requires cursess   celery.events.cursesmont   evtopc          [@  s   d S(   Ns   me top, you?(    (   R   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyR   '   R   s   celery.bin.eventsR   c           @  s4     j    j j   d    j d t j d  d  S(   Ns   me top, you?s   celery events:topi    (   R   R   R   R   R   R   (    (   R
   (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   _inner&   s    (   t   cursest   ImportErrorR   R   R   (   R
   R#   R"   (    (   R
   s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   test_run_top    s    		$s   celery.events.snapshott   evcamc          O@  s
   |  | f S(   N(    (   t   at   k(    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyR   /   R   c         C@  s   |  j  j d d d d  \ } } |  j | d d  |  j | d d  |  j | d  |  j | d d	  |  j | d d  |  j d
 t j d  d  S(   Nt   cameras   foo.bar.bazt   logfilei    t   freqg      ?t   maxratet   loglevelt   INFOs   celery events:cam(   R   R   R   t   assertIsNoneR   R   R   (   R
   R'   R   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   test_run_cam.   s    !s   celery.events.snapshot.evcams   celery.bin.events.detachedc         C@  sF   d |  j  _ |  j  j d d t |  j | j  |  j | j  d  S(   Ns   celery eventss   myapp.Camerat   detach(   R   t	   prog_namet	   run_evcamR	   t
   assertTruet   called(   R
   t   detachedR&   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   test_run_cam_detached:   s    c         C@  s   |  j  |  j j    d  S(   N(   R4   R   t   get_options(   R
   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   test_get_optionsB   s    R   c         C@  s'   g  t  _ t j   |  j t  j  d  S(   N(   R   R   R   t   mainR4   (   R
   (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt	   test_mainE   s    	
(   R   R   R   R   R   R    R%   R0   R   R7   R9   R   R;   (    (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyR      s   						
		N(    (   t
   __future__R    t
   celery.binR   t   celery.tests.caseR   R   R   R   t   objectR   t   NoneR   R   R   (    (    (    s>   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/bin/test_events.pyt   <module>   s   "	