
P'^c           @@  s  d  d l  m Z d  d l Z d  d l Z d  d l m Z d  d l m Z d  d l m	 Z	 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  d l m Z d  d l m Z m Z m Z 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$ e j% d  d k sge& e d d  rpd Z( n e j) d d0 i   Z( e d e* d  Z+ e d e# d  Z, e d e$ d  Z- d e f d     YZ. d e f d     YZ/ d e f d     YZ0 d  e f d!     YZ1 d" e f d#     YZ2 d$ e f d%     YZ3 d& e f d'     YZ4 d( e f d)     YZ5 d* e f d+     YZ6 d, e f d-     YZ7 d. e f d/     YZ8 d S(1   i    (   t   absolute_importN(   t   contextmanager(   t
   ChordError(   t   itemst   range(   t   serialization(   t   subclass_exception(   t   find_pickleable_exception(   t   UnpickleableExceptionWrapper(   t   get_pickleable_exception(   t   states(   t   group(   t   BaseBackendt   KeyValueStoreBackendt   DisabledBackend(   t   result_from_tuple(   t   uuid(   t   AppCaset   Mockt   SkipTestt   patcht
   wrapobjectc           B@  s   e  Z d    Z RS(   c         O@  s   | |  _  d  S(   N(   t   args(   t   selfR   t   kwargs(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   __init__   s    (   t   __name__t
   __module__R   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR      s   i   t   pypy_version_infot   Oldstylet   Unpickleables
   foo.modulet
   Impossiblet	   Lookaliket   test_serializationc           B@  s   e  Z d    Z RS(   c         C@  s9   |  j  t j d d   |  j  t j d d t   d  S(   Nt   FooErrort   m(   t
   assertTrueR   t   create_exception_clst   KeyError(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_create_exception_cls-   s    (   R   R   R'   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR!   +   s   t   test_BaseBackend_interfacec           B@  s8   e  Z d    Z d   Z d   Z d   Z d d  Z RS(   c         C@  s   t  |  j  |  _ d  S(   N(   R   t   appt   b(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   setup5   s    c         C@  s*   |  j  t   |  j j d  Wd  QXd  S(   Ns   SOMExx-N0Nex1stant-IDxx-(   t   assertRaisest   NotImplementedErrorR*   t   _forget(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test__forget8   s    c         C@  s*   |  j  t   |  j j d  Wd  QXd  S(   Ns   SOMExx-N0nex1stant-IDxx-(   R,   R-   R*   t   forget(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_forget<   s    c         C@  s   |  j  j d  d  d   d  S(   N(   R*   t   on_chord_part_returnt   None(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_on_chord_part_return@   s    s   celery.chord_unlockc      
   C@  s   t    |  j j | <|  j j t d |  j  d d d  d g  d d d g D] } |  j j |  ^ qG |  j |  j j | j	 j
  d  S(   NR)   t   dakj221t   resulti   i   i   (    (   R   R)   t   tasksR*   t   apply_chordR   R3   t   AsyncResultR$   t   apply_asynct
   call_count(   R   t   unlockt   x(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_apply_chordC   s
    	/(   R   R   R+   R/   R1   R4   R>   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR(   3   s
   				t   test_exception_picklec           B@  s,   e  Z d    Z d   Z d   Z d   Z RS(   c         C@  s5   t  d  k r t d   n  |  j t t      d  S(   Ns'   py3k does not support old style classes(   R   R3   R   R$   t   fnpe(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_oldstyleN   s    c         C@  s   |  j  t t     d  S(   N(   t   assertIsNoneR@   t	   Exception(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_BaseExceptionS   s    c         C@  s&   t  d  } |  j t |  |  d  S(   Nt   foo(   RC   t   assertEqualt   gpe(   R   t   exc(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_get_pickleable_exceptionV   s    c         C@  s3   |  j  t t    t  |  j t t     d  S(   N(   t   assertIsInstanceR@   R   R&   RB   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_unpickleableZ   s    (   R   R   RA   RD   RI   RK   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR?   L   s   			t   test_prepare_exceptionc           B@  s,   e  Z d    Z d   Z d   Z d   Z RS(   c         C@  s   t  |  j  |  _ d  S(   N(   R   R)   R*   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR+   a   s    c         C@  sT   |  j  j t d d d   } |  j | t  |  j  j |  } |  j | t  d  S(   Ni   i   RE   (   R*   t   prepare_exceptionR   RJ   R&   t   exception_to_python(   R   R=   t   y(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyRK   d   s    c         C@  s   |  j  j t    } |  j | t  |  j t |   |  j  j |  } |  j | j	 j
 d  t j d k  r |  j | j	 j  n |  j | j	 j d  d  S(   NR   i   i   s
   foo.module(   i   i   (   R*   RM   R   RJ   R   R$   t   strRN   RF   t	   __class__R   t   syst   version_infoR   (   R   R=   RO   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_impossiblej   s    c         C@  sN   |  j  j t d   } |  j | t  |  j  j |  } |  j | t  d  S(   Nt   baz(   R*   RM   R&   RJ   RN   (   R   R=   RO   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_regularu   s    (   R   R   R+   RK   RT   RV   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyRL   _   s   			t	   KVBackendc           B@  s;   e  Z e Z d    Z d   Z d   Z d   Z d   Z RS(   c         O@  s#   i  |  _  t t |   j |  d  S(   N(   t   dbt   superRW   R   (   R   R)   R   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR      s    	c         C@  s   |  j  j |  S(   N(   RX   t   get(   R   t   key(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyRZ      s    c         C@  s   | |  j  | <d  S(   N(   RX   (   R   R[   t   value(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   set   s    c         @  sG     j  r# t   f d   | D  Sg  | D] }   j |  ^ q* Sd  S(   Nc         3@  s$   |  ] } |   j  |  f Vq d  S(   N(   RZ   (   t   .0R[   (   R   (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pys	   <genexpr>   s    (   t   mget_returns_dictt   dictRZ   (   R   t   keyst   k(    (   R   sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   mget   s    	c         C@  s   |  j  j | d   d  S(   N(   RX   t   popR3   (   R   R[   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   delete   s    (	   R   R   t   FalseR_   R   RZ   R]   Rc   Re   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyRW   |   s   				t   DictBackendc           B@  s,   e  Z d    Z d   Z d   Z d   Z RS(   c         O@  s.   t  j |  | |  i i d d 6d 6|  _ d  S(   NRE   R6   s
   can-delete(   R   R   t   _data(   R   R   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR      s    c         C@  s   | d k r i d d 6Sd  S(   Nt   existsR   R6   (    (   R   t   group_id(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   _restore_group   s    c         C@  s   | d k r i d d 6Sd  S(   Ns   task-existst   taskR6   (    (   R   t   task_id(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   _get_task_meta_for   s    c         C@  s   |  j  j | d   d  S(   N(   Rh   Rd   R3   (   R   Rj   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   _delete_group   s    (   R   R   R   Rk   Rn   Ro   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyRg      s   			t   test_BaseBackend_dictc           B@  sk   e  Z d    Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z	 d   Z
 d	   Z d
   Z RS(   c         C@  s   t  d |  j  |  _ d  S(   NR)   (   Rg   R)   R*   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR+      s    c         C@  s*   |  j  j d  |  j d |  j  j  d  S(   Ns
   can-delete(   R*   t   delete_groupt   assertNotInRh   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_delete_group   s    c         C@  sy   t  |  j d d } | j t d   } |  j d |  | j |  } |  j | j j d  |  j t	 |  d  d  S(   Nt
   serializert   jsonRE   t   exc_typeR&   s   'foo'(
   Rg   R)   RM   R&   t   assertInRN   RF   RQ   R   RP   (   R   R=   t   e(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_prepare_exception_json   s    c         C@  sB   t  |  j  } t   | _ | j d d  | j j d d  d  S(   Nt   foofoot   xxx(   R   R)   R   t   _save_groupt
   save_groupt   assert_called_with(   R   R*   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_save_group   s    c         C@  s6   t  |  j  } |  j t   | j d  Wd  QXd  S(   NRE   (   R   R)   R,   R-   R0   (   R   R*   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_forget_interface   s    c         C@  s   |  j  |  j j d   |  j  |  j j d   |  j |  j j d  d  |  j |  j j d  d  |  j |  j j d d t d  d  S(   Nt   missingRi   R   t   cache(   RB   R*   t   restore_groupRF   Rf   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_restore_group   s
    c         C@  s7   i  |  j  _ |  j  j d  i d d 6|  j  j d <d  S(   NRi   R   R6   (   R*   t   _cachet   reload_group_result(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_reload_group_result   s    c         C@  s7   i  |  j  _ |  j  j d  i d d 6|  j  j d <d  S(   Ns   task-existsRl   R6   (   R*   R   t   reload_task_result(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_reload_task_result   s    c         C@  s   t    |  j _ y t d   Wn t k
 r } |  j j d  |  j |  j j j  |  j j j d } |  j | d d  |  j	 | d |  |  j | d  n Xd  S(   NRE   Rm   i    i   i   (
   R   R*   t   mark_as_failureR&   t   fail_from_current_stackR$   t   calledt	   call_argsRF   t   assertIs(   R   RH   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_fail_from_current_stack   s    c         C@  s   d |  j  _ |  j j d |  j j d  g  } |  j  j |  } |  j | t t f  |  j	 t
 | d |  j |  |  j  j | d  } |  j | t t f  |  j	 t
 | d |  j | d  d |  j  _ |  j |  j  j |  |  j j  d  S(   NRu   Rj   RE   R)   i    t   pickle(   R*   Rt   R)   t   GroupResultR9   t   prepare_valueRJ   t   listt   tupleRF   R   (   R   t   gt   vt   v2(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt*   test_prepare_value_serializes_group_result   s    $#c         C@  sU   t  d |  j d d  } d | j d <|  j | j d   |  j | j d   d  S(   NR)   t   max_cached_resultsi   RE   t   false(   R   R)   R   R$   t	   is_cachedt   assertFalse(   R   R*   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_is_cached   s    (   R   R   R+   Rs   Ry   R   R   R   R   R   R   R   R   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyRp      s   										t   test_KeyValueStoreBackendc           B@  s   e  Z d    Z d   Z d   Z d   Z d   Z d   Z d   Z e	 d    Z
 d   Z d	   Z d
   Z d   Z d   Z d   Z d   Z d   Z d   Z d   Z RS(   c         C@  s   t  d |  j  |  _ d  S(   NR)   (   RW   R)   R*   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR+      s    c         C@  s-   |  j  j s t  |  j  j d  d  d   d  S(   N(   R*   t   implements_incrt   AssertionErrorR2   R3   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR4      s    c         C@  s   t    } |  j j | d  |  j |  j j |  d  |  j |  j j |  t j  |  j j |  |  j |  j j |  t j	  d  S(   Ns   Hello world(
   R   R*   t   mark_as_doneRF   t
   get_resultt
   get_statusR
   t   SUCCESSR0   t   PENDING(   R   t   tid(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_get_store_delete_result   s    	c         C@  sN   |  j  j d  } |  j |  j  j |  d  |  j |  j  j d  d  d  S(   Nt   x1b34(   R*   t   get_key_for_taskRF   t   _strip_prefix(   R   R=   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_strip_prefix  s    c         C@  s   x t  t f D] } | |  j _ t d   t d  D  } x- t |  D] \ } } |  j j | |  qH W|  j j t	 |   } x8 t
 |  D]* \ } \ } } |  j | d | |  q W|  j | d  |  j t	 |  j j t	 |     q Wd  S(   Nc         s@  s   |  ] } t    | f Vq d  S(   N(   R   (   R^   t   i(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pys	   <genexpr>  s    i
   R6   i	   (   t   TrueRf   R*   R_   R`   R   R   R   t   get_manyR   t	   enumerateRF   R$   (   R   t   is_dictt   idst   idR   t   itt   got_idt	   got_state(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_get_many	  s    c         C@  s   g  t  d  D] } t   ^ q } i d d 6|  j j | d <|  j |  j j  ' t |  j j | d d d d  Wd  QXd  S(   Ni   R   t   statusi   t   timeoutg{Gz?t   interval(   R   R   R*   R   R,   t   TimeoutErrorR   R   (   R   t   _R7   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_get_many_times_out  s    "c         C@  st   t  |  j _ t   } d } d } d  | j _ t   |  j _ t d  |  j j _	 |  j
 |  j j | | |   d  S(   NR   i
   s   should not get here(   R   R*   R   R   R3   t   requestR   t   get_key_for_chordR   t   side_effectRB   R2   (   R   Rl   t   stateR6   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_chord_part_return_no_gid  s    	c         c@  s  |  j  j d t  d    } t | _ t   | _ t d   } t d d  } | j _	 t   | _
 d | j
 _	 t   | _ d | j _	 t   | _ t   } d | j _ | j   } | j _ | j j j   | | _ t   | j _ | | | f VWd  QXd  S(   Nt   sharedc         S@  s   d  S(   N(    (   R6   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   callback*  s    s    celery.backends.base.GroupResultt   namet   DEPSi
   t   grid(   R)   Rl   Rf   R   R   R   t   clientR   t   restoret   return_valuet   __len__t   incrt   expireR   R   t   st   chordt   freezet   backendR   (   R   R*   R   t   GRt   depsRl   t   cb(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   _chord_part_context'  s"    			c      
   C@  s   |  j  |  j  h \ } } } |  j j | d d d t |  j |  j j j  | j j   | j	 j d t d d  Wd  QXd  S(   NR   i
   t	   propagateR   g      @(
   R   R*   R2   R   R   R   R   Re   R~   t   join_native(   R   Rl   R   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt$   test_chord_part_return_propagate_set?  s
    c      
   C@  s   |  j  |  j  t \ } } } |  j j | d d d d  |  j |  j j j  | j j   | j	 j d |  j j
 j j d d  Wd  QXd  S(   NR   i
   R   R   g      @(   R   R*   R2   R3   R   R   R   Re   R~   R   R)   t   conft   CELERY_CHORD_PROPAGATES(   R   Rl   R   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt(   test_chord_part_return_propagate_defaultF  s    c         C@  s   |  j  |  j   \ } } } d   | _ t d  | j _ |  j j | d d  |  j |  j j j	  |  j j j
 } | d d } |  j | t  |  j d t |   Wd  QXd  S(   Nc           S@  s
   t  g   S(   N(   t   iter(    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   <lambda>R  t    RE   R   i
   i   RH   (   R   R*   t   _failed_join_reportR&   R   R   R2   R$   R   R   R   RJ   R   Rw   RP   (   R   Rl   R   R   R   RH   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt+   test_chord_part_return_join_raises_internalP  s    c         @  s   t  d d d   j  }   j |   \ } } }   f d   | _ t d  | j _ | j | d d    j | j	 j
  | j	 j } | d d	 }   j | t    j d
 t |   Wd  QXd  S(   NRt   R   R)   c           @  s   t    j j d  g  S(   Nt   culprit(   R   R)   R9   (    (   R   (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR   ^  s   RE   R   i
   i   RH   s   Dependency culprit raised(   RW   R)   R   R   R&   R   R   R2   R$   R   R   R   RJ   R   Rw   RP   (   R   R*   Rl   R   R   R   RH   (    (   R   sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt'   test_chord_part_return_join_raises_task[  s    c         C@  s   t  d d d |  j  } |  j j d |  j j d  |  j j d  g  } | j | j |  | j | j  d } |  j | |  d  S(   NRt   Ru   R)   Rj   t   aR*   R6   (   RW   R)   R   R9   R|   R   Rk   RF   (   R   R*   R   t   g2(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_restore_group_from_jsoni  s    	'c         C@  s   t  d d d |  j  } |  j j d |  j j d  |  j j d  g  } | j | j |  | j | j  d } |  j | |  d  S(   NRt   R   R)   Rj   R   R*   R6   (   RW   R)   R   R9   R|   R   Rk   RF   (   R   R*   R   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_restore_group_from_pickles  s    	'c      	   C@  sr   t  |  j _ t   |  j _ |  j j t d |  j  d d d d d d d |  j j j d d d d d d d  S(   NR)   Rj   t   bodyR6   RE   i   (    (	   Rf   R*   R   R   t   fallback_chord_unlockR8   R   R)   R~   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_chord_apply_fallback}  s    	c         C@  s<   |  j  |  j j d   |  j |  j j d  t j  d  S(   Ns   xxx-missing(   RB   R*   R   RF   R   R
   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_get_missing_meta  s    c         C@  s   t    } |  j j | g  t d  D] } |  j j t     ^ q"  } |  j j | |  |  j j |  |  j |  j j |  |  |  j j	 |  |  j
 |  j j |   d  S(   Ni
   (   R   R)   R   R   R9   R*   R}   R   RF   Rq   RB   (   R   R   R   t   tsr(    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_save_restore_delete_group  s    		4c         C@  s   |  j  |  j j d   d  S(   Ns   xxx-nonexistant(   RB   R*   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_restore_missing_group  s    (   R   R   R+   R4   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR      s$   									
			
	
			t#   test_KeyValueStoreBackend_interfacec           B@  sG   e  Z d    Z d   Z d   Z d   Z d   Z d   Z d   Z RS(   c         C@  s0   |  j  t   t |  j  j d  Wd  QXd  S(   NR   (   R,   R-   R   R)   RZ   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_get  s    c         C@  s3   |  j  t   t |  j  j d d  Wd  QXd  S(   NR   i   (   R,   R-   R   R)   R]   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_set  s    c         C@  s0   |  j  t   t |  j  j d  Wd  QXd  S(   NR   (   R,   R-   R   R)   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt	   test_incr  s    c         C@  s    |  j  t |  j  j    d  S(   N(   R   R   R)   t   cleanup(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_cleanup  s    c         C@  s0   |  j  t   t |  j  j d  Wd  QXd  S(   NR   (   R,   R-   R   R)   Re   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_delete  s    c         C@  s3   |  j  t   t |  j  j d g  Wd  QXd  S(   NR   (   R,   R-   R   R)   Rc   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt	   test_mget  s    c         C@  s0   |  j  t   t |  j  j d  Wd  QXd  S(   NR   (   R,   R-   R   R)   R0   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR1     s    (	   R   R   R   R   R   R   R   R   R1   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR     s   						t   test_DisabledBackendc           B@  s#   e  Z d    Z d   Z d   Z RS(   c         C@  s   t  |  j  j   d  S(   N(   R   R)   t   store_result(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_store_result  s    c         C@  s0   |  j  t   t |  j  j d  Wd  QXd  S(   NRE   (   R,   R-   R   R)   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_is_disabled  s    c         C@  s#   |  j  t |  j  j   d  d  S(   Ns   disabled://(   RF   R   R)   t   as_uri(   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_as_uri  s    (   R   R   R   R   R   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR     s   		R   c           B@  s#   e  Z d    Z d   Z d   Z RS(   c         C@  s   t  d |  j d d  |  _ d  S(   NR)   t   urls   sch://uuuu:pwpw@hostname.dom(   R   R)   R*   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR+     s    	c         C@  s&   |  j  |  j j t  |  j j  d  S(   N(   RF   R*   R   R   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_as_uri_include_password  s    c         C@  s   |  j  |  j j   d  d  S(   Ns   sch://uuuu:**@hostname.dom/(   RF   R*   R   (   R   (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   test_as_uri_exclude_password  s    (   R   R   R+   R   R   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyR     s   		(    (9   t
   __future__R    RR   t   typest
   contextlibR   t   celery.exceptionsR   t   celery.fiveR   R   t   celery.utilsR   t   celery.utils.serializationR   R   R@   R   R	   RG   t   celeryR
   R   t   celery.backends.baseR   R   R   t   celery.resultR   R   t   celery.tests.caseR   R   R   R   t   objectR   RS   t   getattrR3   R   t	   ClassTypeR&   R   R   R    R!   R(   R?   RL   RW   Rg   Rp   R   R   R   R   (    (    (    sA   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/backends/test_base.pyt   <module>   sD   "%	N