ó
P'—^c           @@  sî   d  d l  m Z d  d l m Z d  d l m Z d  d l m Z d  d l m	 Z	 d  d l
 m Z d  d l m Z d e f d	 „  ƒ  YZ d
 e j f d „  ƒ  YZ d „  Z d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d S(   i    (   t   absolute_import(   t   wraps(   t   Mailbox(   t   control(   t   DuplicateNodenameWarning(   t   uuid(   t   AppCaset   MockMailboxc           B@  s)   e  Z g  Z d  „  Z d „  Z d „  Z RS(   c         O@  s   |  j  j j | ƒ d  S(   N(   t	   __class__t   sentt   append(   t   selft   commandt   argst   kwargs(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   _publish   s    c         C@  s   d  S(   N(    (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   close   s    c         O@  s   d  S(   N(    (   R   R   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   _collect   s    (   t   __name__t
   __module__R	   R   R   R   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyR      s   		t   Controlc           B@  s   e  Z e Z RS(    (   R   R   R   R   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyR      s   c         @  s   t  ˆ  ƒ ‡  f d †  ƒ } | S(   Nc          @  s+   g  t  _ z ˆ  |  | Ž  SWd  g  t  _ Xd  S(   N(   R   R	   (   R   R   (   t   fun(    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   _resets    s    	(   R   (   R   R   (    (   R   s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   with_mock_broadcast   s    t   test_flatten_replyc           B@  s   e  Z d  „  Z RS(   c         C@  s   i i d d 6d 6i i d d 6d 6i i d d 6d 6g } |  j  t ƒ  } t j | ƒ } Wd  QX|  j d t | j ƒ ƒ |  j d | ƒ |  j d | ƒ d  S(   Ni
   t   hellos   foo@example.comi   i   s   bar@example.coms:   Received multiple replies from node name: foo@example.com.(   t   assertWarnsR   R   t   flatten_replyt   assertInt   strt   warning(   R   t   replyt   wt   nodes(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyR   ,   s    (   R   R   R   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyR   *   s   t   test_inspectc           B@  sû   e  Z d  „  Z d „  Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z	 e d „  ƒ Z
 e d „  ƒ Z e d	 „  ƒ Z e d
 „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z RS(   c         C@  sJ   t  d |  j ƒ |  _ |  j j |  j |  _ |  j _ |  j j ƒ  |  _ d  S(   Nt   app(   R   R#   t   cR   t   prevt   inspectt   i(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   setup?   s    c         C@  s¤   |  j  |  j j i i d d 6d 6i i d d 6d 6g ƒ i i d d 6d 6i d d 6d 6ƒ |  j j d d ƒ } |  j | j i i d d 6d 6g ƒ i d d 6ƒ d  S(   Ni   t   okt   w1t   w2t   destination(   t   assertDictEqualR'   t   _prepareR$   R&   t   assertEqual(   R   R'   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_prepare_replyD   s     ##c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   dump_active(   R'   t   activeR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_activeM   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   clock(   R'   R4   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt
   test_clockR   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt	   dump_conf(   R'   t   confR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt	   test_confW   s    c         C@  s'   |  j  j d ƒ |  j d t j ƒ d  S(   Ns   george@vandelay.comR   (   R'   R   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt
   test_hello\   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt	   memsample(   R'   R:   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_memsamplea   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   memdump(   R'   R<   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_memdumpf   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   objgraph(   R'   R>   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_objgraphk   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   dump_schedule(   R'   t	   scheduledR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_scheduledp   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   dump_reserved(   R'   t   reservedR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_reservedu   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   stats(   R'   RF   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt
   test_statsz   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   dump_revoked(   R'   t   revokedR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_revoked   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt
   dump_tasks(   R'   t
   registeredR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt
   test_tasks„   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   ping(   R'   RN   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt	   test_ping‰   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   active_queues(   R'   RP   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_active_queuesŽ   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   report(   R'   RR   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_report“   s    (   R   R   R(   R0   R   R3   R5   R8   R9   R;   R=   R?   RB   RE   RG   RJ   RM   RO   RQ   RS   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyR"   =   s"   			t   test_Broadcastc           B@  s
  e  Z d  „  Z d „  Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z	 e d „  ƒ Z
 e d „  ƒ Z e d	 „  ƒ Z e d
 „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z e d „  ƒ Z RS(   c         C@  sO   t  d |  j ƒ |  _ |  j |  j _ |  j j d t ƒ d „  ƒ } | |  _ d  S(   NR#   t   sharedc           S@  s   d  S(   N(    (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   mytaskŸ   s    (   R   R#   R   t   taskt   FalseRV   (   R   RV   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyR(   ›   s    c         C@  s   |  j  j ƒ  d  S(   N(   R   t   purge(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt
   test_purge¤   s    c         C@  s-   |  j  j d d g  ƒ|  j d t j ƒ d  S(   Nt	   foobarbazt	   arguments(   R   t	   broadcastR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_broadcast§   s    c      
   C@  sB   |  j  j d d g  d d  d d d d g ƒ|  j d t j ƒ d  S(   Nt
   foobarbaz1R\   t   limitR,   i   i   i   (   R   R]   t   NoneR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_broadcast_limit¬   s    	"c         C@  s0   |  j  t ƒ  |  j j d d d ƒWd  QXd  S(   Nt
   foobarbaz2R,   t   foo(   t   assertRaisest
   ValueErrorR   R]   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_broadcast_validate³   s    c         C@  s0   |  j  j |  j j d ƒ |  j d t j ƒ d  S(   Ns   100/mt
   rate_limit(   R   Rh   RV   t   nameR   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_rate_limit¹   s    c         C@  s9   |  j  j |  j j d d d d ƒ|  j d t j ƒ d  S(   Nt   softi
   t   hardi   t
   time_limit(   R   Rm   RV   Ri   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_time_limit¾   s    "c         C@  s'   |  j  j d ƒ |  j d t j ƒ d  S(   NRd   t   add_consumer(   R   Ro   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_add_consumerÃ   s    c         C@  s'   |  j  j d ƒ |  j d t j ƒ d  S(   NRd   t   cancel_consumer(   R   Rq   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_cancel_consumerÈ   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   enable_events(   R   Rs   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_enable_eventsÍ   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   Nt   disable_events(   R   Ru   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_disable_eventsÒ   s    c         C@  s'   |  j  j d ƒ |  j d t j ƒ d  S(   Nt   foozbaazt   revoke(   R   Rx   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_revoke×   s    c         C@  s$   |  j  j ƒ  |  j d t j ƒ d  S(   NRN   (   R   RN   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyRO   Ü   s    c         C@  s-   |  j  j d d d ƒ |  j d t j ƒ d  S(   Nt   some_idt   topict   actiont   election(   R   R}   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_electioná   s    c         C@  s'   |  j  j d ƒ |  j d t j ƒ d  S(   Ni   t	   pool_grow(   R   R   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_pool_growæ   s    c         C@  s'   |  j  j d ƒ |  j d t j ƒ d  S(   Ni   t   pool_shrink(   R   R   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_pool_shrinkë   s    c         C@  s-   |  j  j d ƒ j ƒ  |  j d t j ƒ d  S(   Nt   foozbazzbarRx   (   R#   t   AsyncResultRx   R   R   R	   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_revoke_from_resultð   s    c         C@  st   |  j  j t ƒ  g  g  t d ƒ D] } t ƒ  ^ q D] } |  j  j | ƒ ^ q2 ƒ } | j ƒ  |  j d t j ƒ d  S(   Ni
   Rx   (	   R#   t   GroupResultR   t   rangeR„   Rx   R   R   R	   (   R   R'   t   xt   r(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   test_revoke_from_resultsetõ   s
    A
(   R   R   R(   RZ   R   R^   Rb   Rg   Rj   Rn   Rp   Rr   Rt   Rv   Ry   RO   R~   R€   R‚   R…   RŠ   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyRT   ™   s$   			N(   t
   __future__R    t	   functoolsR   t   kombu.pidboxR   t
   celery.appR   t   celery.exceptionsR   t   celery.utilsR   t   celery.tests.caseR   R   R   R   R   R"   RT   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/app/test_control.pyt   <module>   s   	\