ó
P'—^c           @@  sä  d  d l  m 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 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
 „  Z d „  Z d d „ Z d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e f d „  ƒ  YZ d e  f d „  ƒ  YZ! d e f d „  ƒ  YZ" d e f d „  ƒ  YZ# d e f d „  ƒ  YZ$ d e# f d „  ƒ  YZ% d  e f d! „  ƒ  YZ& d" e f d# „  ƒ  YZ' d$ e f d% „  ƒ  YZ( d& S('   i    (   t   absolute_import(   t   contextmanager(   t   states(   t   IncompleteStreamt   TimeoutError(   t   range(   t   AsyncResultt   EagerResultt   TaskSetResultt   result_from_tuple(   t   uuid(   t   pickle(   t   AppCaset   Mockt   depends_on_current_appt   patchc      	   C@  s"   t  d t ƒ  d |  d | d | ƒ S(   Nt   idt   namet   statet   result(   t   dictR
   (   R   R   R   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt	   mock_task   s    c         C@  s“   d } | d t  j k r7 |  j j | d | d ƒ nX | d t  j k rn |  j j | d | d d | ƒn! |  j j | d | d d | ƒd  S(   Ns   Some tracebackR   R   R   t	   traceback(   R   t   SUCCESSt   backendt   mark_as_donet   RETRYt   mark_as_retryt   mark_as_failure(   t   appt   taskR   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   save_result   s    		i
   c         C@  sv   g  t  | ƒ D] } t d | t j | ƒ ^ q } g  | D] } t |  | ƒ ^ q9 g  | D] } |  j | d ƒ ^ qY S(   Ns   ts%dR   (   R   R   R   R   R   R   (   R   t   sizet   it   tasksR   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   make_mock_group&   s    2 t   test_AsyncResultc           B@  s°   e  Z d  „  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 RS(   c         C@  sÐ   t  d t j d ƒ |  _ t  d t j d ƒ |  _ t  d t j t d ƒ ƒ |  _ t  d t j t d ƒ ƒ |  _	 x6 |  j |  j |  j |  j	 f D] } t
 |  j | ƒ q‹ W|  j j d t ƒ d	 „  ƒ } | |  _ d  S(
   Nt   task1t   thet   task2t   quickt   task3t   brownt   redt   sharedc           S@  s   d  S(   N(    (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   mytask7   s    (   R   R   R   R%   R'   t   FAILUREt   KeyErrorR)   R   t   task4R   R   R   t   FalseR-   (   t   selfR   R-   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   setup.   s    %c         C@  sH   |  j  j d ƒ } |  j | j | j ƒ d | _ |  j | j d ƒ d  S(   Nt   1t   2(   R   R   t   assertEqualt   task_idR   (   R2   t   x(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_compat_properties<   s    	c         C@  s™   |  j  j d ƒ } g  t d ƒ D]! } t t | ƒ | t j ƒ ^ q } i | d 6t j d 6| _ t ƒ  | _	 |  j
 | j ƒ |  j t | j ƒ d ƒ d  S(   NR4   i   t   childrent   status(   R   R   R   R   t   strR   R   t   _cacheR   R   t
   assertTrueR:   R6   t   len(   R2   R8   R!   R:   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_childrenB   s    4c         C@  s  |  j  j t ƒ  ƒ } t d d ƒ | _ i  | j j _ i t j d 6d d 6| j j	 _ t
 t ƒ  t d ƒ t j ƒ | _ |  j t ƒ  | j d t ƒ Wd  QX|  j | j j	 j ƒ t
 t ƒ  d t j ƒ | _ |  j | j d t ƒ d ƒ |  j | j j	 j ƒ d  S(	   NR   R   R;   iT   R   t   foot	   propagatei*   (   R   R   R
   R   R   t   get_task_metat   return_valueR   R   t   wait_forR   R/   R.   t   parentt   assertRaisest   gett   Truet   assertFalset   calledR6   R>   (   R2   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_propagates_for_parentJ   s    !c         C@  sÆ   t  ƒ  } |  j j | ƒ } g  t d ƒ D]! } |  j j t  ƒ  ƒ j ƒ  ^ q( } i | d 6| _ |  j | j ƒ |  j t	 | j ƒ d ƒ i t
 j d 6| _ i d  d 6| j j | <|  j | j ƒ d  S(   Ni
   R:   R;   R   (   R
   R   R   R   t   as_tupleR=   R>   R:   R6   R?   R   R   t   NoneR   t   assertIsNone(   R2   t   tidR8   R!   t   child(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_get_childrenZ   s    	1c         C@  sB  |  j  j d ƒ } i t j d 6d  d 6| j j d <g  t d ƒ D]! } t t	 | ƒ | t j ƒ ^ q@ } t
 ƒ  | _ d  | f | | d f | d | d f | d | d f f | j _ t j | j _ |  j | j ƒ |  j | j ƒ  d ƒ | j ƒ  } |  j t | ƒ | d  f | d d f | d d f | d d f g ƒ d  S(   NR4   R;   R   i   i    i   i   (   R   R   R   R   RN   R   R=   R   R   R<   R   t   iterdepsRD   t   READY_STATESR>   t   grapht   assertIst   get_leaft   collectt   assertListEqualt   list(   R2   R8   R!   t   ct   it(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt!   test_build_graph_get_leaf_collectg   s"    !4		c         C@  sF  |  j  j d ƒ } g  t d ƒ D]! } t t | ƒ | t j ƒ ^ q } i t j d 6d  d 6| d 6| _ x) | D]! } t	 ƒ  | _
 g  | j
 j _ qn W| j ƒ  } |  j t | ƒ d  | f | | d f | | d f | | d f g ƒ d  | _ t	 ƒ  | _ t | j _ |  j t ƒ  t | j ƒ  ƒ Wd  QXt | j d	 t ƒ ƒ d  S(
   NR4   i   R;   R   R:   i    i   i   t   intermediate(   R   R   R   R   R<   R   R   RN   R=   R   R   t   get_childrenRD   RS   RY   RZ   t   readyR1   RG   R   RI   (   R2   R8   R!   R[   RQ   R\   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_iterdeps   s$    4!		c         C@  s&   |  j  |  j j d ƒ t ƒ  k ƒ d  S(   NR4   (   RJ   R   R   t   object(   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_eq_not_implemented”   s    c         C@  s   |  j  j d d |  j j ƒ} t j t j | ƒ ƒ } |  j | j d ƒ |  j | j	 |  j j ƒ |  j  j d ƒ } |  j t j t j | ƒ ƒ j d ƒ d  S(   NR
   t	   task_name(
   R   R   R-   R   R   t   loadst   dumpsR6   R   Rd   (   R2   t   a1t   restoredt   a2(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_reduce—   s    c         C@  s°   |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j | j ƒ  ƒ |  j | j ƒ  ƒ |  j | j ƒ  ƒ |  j  j t ƒ  ƒ } |  j | j ƒ  ƒ d  S(   NR   (	   R   R   R%   R)   R0   R>   t
   successfulRJ   R
   (   R2   t   ok_rest   nok_rest   nok_res2t   pending_res(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_successful¡   s    c         C@  s×   |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j t | ƒ |  j d ƒ |  j t | ƒ |  j d ƒ |  j t | ƒ |  j d ƒ t ƒ  } |  j  j | ƒ } |  j t | ƒ | ƒ d  S(   NR   (   R   R   R%   R'   R)   R6   R<   R
   (   R2   Rl   t   ok2_resRm   t
   pending_idRo   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_str­   s    	c         C@  sç   |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j t | ƒ d |  j d ƒ |  j t | ƒ d |  j d ƒ |  j t | ƒ d |  j d ƒ t ƒ  } |  j  j | ƒ } |  j t | ƒ d | ƒ d  S(   NR   s   <AsyncResult: %s>(   R   R   R%   R'   R)   R6   t   reprR
   (   R2   Rl   Rq   Rm   Rr   Ro   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt	   test_repr¹   s    	c         C@  sl   |  j  t |  j j d ƒ ƒ t |  j j d ƒ ƒ ƒ |  j t |  j j d ƒ ƒ t |  j j d ƒ ƒ ƒ d  S(   Nt   x0w991t   x1w991(   R6   t   hashR   R   t   assertNotEqual(   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt	   test_hashÉ   s    c         C@  s¤   |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j | j ƒ |  j | j ƒ |  j | j ƒ |  j  j t ƒ  ƒ } |  j | j ƒ d  S(   NR   (	   R   R   R%   R)   R0   RJ   R   R>   R
   (   R2   Rl   Rm   Rn   Ro   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_get_tracebackÏ   s    c         C@  só   |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j  j |  j d ƒ } |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j t	 ƒ  | j ƒ  Wd  QX|  j
 | j d t ƒ ƒ |  j | j t	 ƒ |  j | j d ƒ d  S(   NR   R&   R(   RB   (   R   R   R%   R'   R)   R0   R6   RH   RG   R/   R>   R1   t   assertIsInstanceR   t   info(   R2   Rl   Rq   Rm   t   nok2_res(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_getÚ   s    c         C@  s©   |  j  j |  j d ƒ } |  j t ƒ  | j d d ƒ Wd  QX|  j  j t ƒ  ƒ } t d ƒ C } |  j t ƒ + | j d d d d ƒ | j j	 d ƒ Wd  QXWd  QXd  S(   NR   t   timeoutgü©ñÒMbP?s   celery.result.timet   interval(
   R   R   R0   RG   R   RH   R
   R   t   sleept   assert_called_with(   R2   t   resRo   t   _time(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_get_timeoutè   s    c         C@  sn   |  j  j |  j d ƒ } t d ƒ C } |  j t ƒ + | j d d d d ƒ | j j d ƒ Wd  QXWd  QXd  S(   NR   s   celery.result.timeR€   i   R   (	   R   R   R0   R   RG   R   RH   R‚   Rƒ   (   R2   R„   R…   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_get_timeout_longeró   s
    c         C@  s±   |  j  j |  j d ƒ |  j  j |  j d ƒ |  j  j |  j d ƒ f } |  j t d „  | Dƒ ƒ ƒ |  j |  j  j |  j d ƒ j	 ƒ  ƒ |  j |  j  j t
 ƒ  ƒ j	 ƒ  ƒ d  S(   NR   c         s@  s   |  ] } | j  ƒ  Vq d  S(   N(   R`   (   t   .0R   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pys	   <genexpr>þ   s    (   R   R   R%   R'   R)   R>   t   allRJ   R0   R`   R
   (   R2   t   oks(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt
   test_readyú   s    &(   t   __name__t
   __module__R3   R9   R@   RL   RR   R]   Ra   Rc   R   Rj   Rp   Rs   Ru   Rz   R{   R   R†   R‡   R‹   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR$   ,   s$   								
								t   test_ResultSetc           B@  sh   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z e d „  ƒ Z d „  Z	 d „  Z
 d „  Z d	 „  Z RS(
   c         C@  sK   |  j  t |  j j g  d d d g D] } |  j j | ƒ ^ q" ƒ ƒ ƒ d  S(   NR4   R5   t   3(   R>   Rt   R   t	   ResultSetR   (   R2   t   t(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_resultset_repr  s    c         C@  s]   |  j  |  j j d d d g ƒ d k ƒ |  j |  j j d g ƒ |  j j d g ƒ k ƒ d  S(   Ni   i   (   RJ   R   R   R>   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_eq_other
  s    (c         C@  s¹   |  j  j g  d d d g D] } |  j  j | ƒ ^ q ƒ } t ƒ  } | j d _ t | _ t ƒ  | _ t ƒ  | _	 | j
 ƒ  |  j | j	 j ƒ t | _ | j
 ƒ  |  j | j j ƒ d  S(   Ni   i   i   i    (   R   R   R   R   t   resultsR   R1   t   supports_native_joint   join_nativet   joinRH   R>   RK   RI   (   R2   R‘   R8   t   b(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR     s    :	
	
c         C@  sU   |  j  j g  ƒ } |  j | j ƒ t d d ƒ | _ | j ƒ  |  j | j j ƒ d  S(   NR   R—   (	   R   R   RO   R•   R   R—   RH   R>   RK   (   R2   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_get_empty  s
    
c         C@  s_   |  j  j d g ƒ } | j d ƒ |  j t | ƒ d ƒ | j d ƒ |  j t | ƒ d ƒ d  S(   Ni   i   (   R   R   t   addR6   R?   (   R2   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_add!  s
    c         c@  s0   t  d ƒ  } d „  } | | _ d  VWd  QXd  S(   Ns   celery.result.copyc         S@  s   |  S(   N(    (   t   arg(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   passt,  s    (   R   t   side_effect(   R2   t   copyR   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt
   dummy_copy(  s    		c         @  s‹  |  j  j t ƒ  ƒ } |  j  j t ƒ  ƒ } t ƒ  } | _ | _ d | _ t ƒ  ‰  | _ | _ ‡  f d †  } t ˆ  _ | ˆ  _	 |  j  j
 | | g ƒ } |  j ƒ  ß t d ƒ P } |  j ƒ  + |  j t ƒ  t | j ƒ  ƒ Wd  QXWd  QX| j j d ƒ Wd  QXd | _ t d ƒ e } |  j ƒ  P |  j t ƒ ' t ˆ  _ | ˆ  _	 t | j ƒ  ƒ Wd  QX|  j | j j ƒ Wd  QXWd  QXWd  QXd  S(   Ni
   c          @  s   t  ƒ  ˆ  _ t S(   N(   R/   Rž   R1   (   t   argst   kwargs(   R`   (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   se:  s    s   celery.result.timei    (   R   R   R
   R   R   t   subpolling_intervalR`   R1   RD   Rž   R   R    R   t   assertPendingDeprecationRG   R/   RZ   t   iterateR‚   Rƒ   RJ   RK   (   R2   t   r1t   r2R   R£   R8   R…   (    (   R`   s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt)   test_iterate_respects_subpolling_interval2  s.    						c         C@  s¨   |  j  j t ƒ } t ƒ  | _ t | j _ |  j  j | g ƒ } |  j ƒ  W t	 d ƒ D |  j
 ƒ  1 |  j t ƒ  t | j d d ƒ ƒ Wd  QXWd  QXWd  QXWd  QXd  S(   Ns   celery.result.timeR€   i   (   R   R   R
   R   R`   R1   RD   R   R    R   R¥   RG   R   RZ   R¦   (   R2   R§   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_times_outQ  s    c         C@  sÈ   |  j  j g  ƒ } | j |  j  j d ƒ ƒ |  j |  j  j d ƒ | j ƒ | j |  j  j d ƒ ƒ | j |  j  j d ƒ ƒ | j d ƒ |  j |  j  j d ƒ | j ƒ | j |  j  j d ƒ g ƒ d  S(   NR4   R5   (	   R   R   Rš   R   t   assertInR”   t   discardt   assertNotInt   update(   R2   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_add_discard\  s    c         C@  s<   |  j  j g  ƒ } | j } | j ƒ  |  j | j | ƒ d  S(   N(   R   R   R”   t   clearRV   (   R2   R8   t   r(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt
   test_clearg  s    	
(   RŒ   R   R’   R“   R   R™   R›   R   R    R©   Rª   R¯   R²   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRŽ     s   					
			t   MockAsyncResultFailurec           B@  s2   e  Z e d  „  ƒ Z e d „  ƒ Z e d „ Z RS(   c         C@  s
   t  d ƒ S(   Nt   baz(   R/   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR   p  s    c         C@  s   t  j S(   N(   R   R.   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR   t  s    c         K@  s   | r |  j  ‚ n  |  j  S(   N(   R   (   R2   RB   R¢   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRH   x  s    (   RŒ   R   t   propertyR   R   RI   RH   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR³   n  s   t   MockAsyncResultSuccessc           B@  s>   e  Z e Z d  „  Z e d „  ƒ Z e d „  ƒ Z d „  Z RS(   c         C@  s   t  |  _ d  S(   N(   RI   t	   forgotten(   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   forget  s    c         C@  s   d S(   Ni*   (    (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR   „  s    c         C@  s   t  j S(   N(   R   R   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR   ˆ  s    c         K@  s   |  j  S(   N(   R   (   R2   R¢   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRH   Œ  s    (	   RŒ   R   R1   R·   R¸   Rµ   R   R   RH   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR¶   ~  s
   	t   SimpleBackendc           B@  s#   e  Z g  Z g  d  „ Z d „  Z RS(   c         C@  s   | |  _  d  S(   N(   t   ids(   R2   Rº   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   __init__“  s    c         O@  s   d „  t  |  j ƒ Dƒ S(   Nc         s@  s2   |  ]( \ } } | i | d  6t  j d 6f Vq d S(   R   R;   N(   R   R   (   Rˆ   R!   R   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pys	   <genexpr>—  s   (   t	   enumerateRº   (   R2   R¡   R¢   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   get_many–  s    (   RŒ   R   Rº   R»   R½   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR¹     s   t   test_TaskSetResultc           B@  s5   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  s1   d |  _  t t ƒ  t |  j |  j  ƒ ƒ |  _ d  S(   Ni
   (   R    R   R
   R#   R   t   ts(   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR3     s    	c         C@  s   |  j  |  j j |  j ƒ d  S(   N(   R6   R¿   t   totalR    (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt
   test_total¡  s    c         C@  sB   |  j  |  j j |  j j ƒ d |  j _ |  j  |  j j d ƒ d  S(   NRA   (   R6   R¿   t
   taskset_idR   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR9   ¤  s    c         C@  s>   t  t ƒ  d d d d g ƒ} |  j | j d d d g ƒ d  S(   Nt   subtasksi   i   i   (   R   R
   R6   R”   (   R2   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_compat_subtasks_kwarg©  s    c         C@  sF   |  j  j ƒ  } x0 t | ƒ D]" \ } } |  j | j ƒ  | ƒ q Wd  S(   N(   R¿   t   itersubtasksR¼   R6   RH   (   R2   R\   R!   R‘   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_itersubtasks­  s    (   RŒ   R   R3   RÁ   R9   RÄ   RÆ   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR¾   ›  s
   				t   test_GroupResultc           B@  s  e  Z d  „  Z e 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 d „  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@  s7   d |  _  |  j j t ƒ  t |  j |  j  ƒ ƒ |  _ d  S(   Ni
   (   R    R   t   GroupResultR
   R#   R¿   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR3   ¶  s    		c         C@  sœ   |  j  j t ƒ  |  j  j t ƒ  ƒ g ƒ } |  j t j t j | ƒ ƒ | ƒ |  j  j t ƒ  |  j  j t ƒ  ƒ g ƒ } |  j t j t j | ƒ ƒ | ƒ d  S(   N(   R   RÈ   R
   R   R6   R   Re   Rf   (   R2   R¿   t   ts2(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_is_pickleable¼  s    *"*c         C@  s    |  j  t |  j ƒ |  j ƒ d  S(   N(   R6   R?   R¿   R    (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_lenÃ  s    c         C@  s   |  j  |  j d k ƒ d  S(   Ni   (   RJ   R¿   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR“   Æ  s    c         C@  s&   |  j  t j t j |  j ƒ ƒ ƒ d  S(   N(   R>   R   Re   Rf   R¿   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRj   É  s    c         C@  sv   t  t ƒ  d |  j ƒ} |  j j t ƒ  | g ƒ } |  j ƒ   | j ƒ  } Wd  QX|  j t ƒ  t | ƒ Wd  QXd  S(   NR   (	   R³   R
   R   RÈ   R¥   R¦   RG   R/   t   next(   R2   t   arR¿   R\   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_iterate_raisesÍ  s    c         C@  sw   t  t ƒ  d |  j ƒt  t ƒ  d |  j ƒg } |  j j t ƒ  | ƒ } | j ƒ  x | D] } |  j | j ƒ qY Wd  S(   NR   (   R¶   R
   R   RÈ   R¸   R>   R·   (   R2   t   subsR¿   t   sub(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_forgetÕ  s    
c         C@  sd   t  t ƒ  d |  j ƒt  t ƒ  d |  j ƒg } |  j j t ƒ  | ƒ } |  j | d | d ƒ d  S(   NR   i    (   R¶   R
   R   RÈ   RV   (   R2   RÏ   R¿   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_getitemÝ  s    c      	   C@  s  t  t ƒ  d |  j ƒt  t ƒ  d |  j ƒg } |  j j t ƒ  | ƒ } | j ƒ  |  j t ƒ  | j d t ƒ  ƒ Wd  QX|  j |  j j j	 | j
 ƒ j | j ƒ | j ƒ  |  j |  j j j	 | j
 ƒ ƒ |  j t ƒ $ |  j j j	 | j
 d t ƒ  ƒWd  QXd  S(   NR   R   (   R¶   R
   R   RÈ   t   saveRG   t   AttributeErrorRb   R6   t   restoreR   RÃ   t   deleteRO   (   R2   RÏ   R¿   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_save_restoreã  s    


c         C@  s¬   t  ƒ  } g  t d ƒ D]! } |  j j t ƒ  d | ƒ^ q } |  j j t ƒ  | ƒ } | | j _ g  | D] } | j ^ qh | _ | j	 ƒ  } |  j
 | t t d ƒ ƒ ƒ d  S(   Ni
   R   (   R¹   R   R   R   R
   RÈ   R   R   Rº   R–   R6   RZ   (   R2   R   R!   RÃ   R¿   t   subtaskR„   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_join_nativeñ  s    	1c         C@  s’   |  j  j t ƒ  |  j  j t ƒ  ƒ g ƒ } t ƒ  | _ t t ƒ  i t j d 6t	 ƒ  d 6f g ƒ | j _
 |  j t	 ƒ  | j d t ƒ Wd  QXd  S(   NR;   R   RB   (   R   RÈ   R
   R   R   t   iter_nativet   iterR   R.   R/   RD   RG   R–   RI   (   R2   R¿   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_join_native_raisesû  s    */c         C@  s”   t  ƒ  } |  j j t ƒ  | g ƒ } t j | _ t | j j	 _
 |  j t | j ƒ  ƒ | ƒ t | j j	 _
 |  j t ƒ  t | j ƒ  ƒ Wd  QXd  S(   N(   R   R   RÈ   R
   R   R.   R   RI   R   t	   is_cachedRD   RV   RÌ   t   _failed_join_reportR1   RG   t   StopIteration(   R2   R„   R¿   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_failed_join_report  s    	c         C@  s;   |  j  t |  j j t ƒ  |  j j t ƒ  ƒ g ƒ ƒ ƒ d  S(   N(   R>   Rt   R   RÈ   R
   R   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRu     s    	c         C@  sD   |  j  j t ƒ  |  j  j t ƒ  ƒ g ƒ } |  j | j | j ƒ d  S(   N(   R   RÈ   R
   R   RV   R:   R”   (   R2   R¿   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_children_is_results  s    *c         C@  s¦   t  ƒ  } g  t d ƒ D]! } |  j j t ƒ  d | ƒ^ q } |  j j t ƒ  | ƒ } | | j _ g  | D] } | j ^ qh | _ |  j	 t
 t | j ƒ  ƒ ƒ d ƒ d  S(   Ni
   R   (   R¹   R   R   R   R
   RÈ   R   R   Rº   R6   R?   RZ   RÚ   (   R2   R   R!   RÃ   R¿   RØ   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_iter_native  s    	1c         C@  s   t  t ƒ  d |  j ƒ} t  t ƒ  d |  j ƒ} |  j j t ƒ  | | g ƒ } |  j ƒ   | j ƒ  } Wd  QX|  j t | ƒ d ƒ |  j t | ƒ d ƒ d  S(   NR   i*   (   R¶   R
   R   RÈ   R¥   R¦   R6   RÌ   (   R2   RÍ   t   ar2R¿   R\   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_iterate_yields   s    c         C@  s   t  t ƒ  d t j ƒ } t  t ƒ  d t j ƒ } |  j j t ƒ  | | g ƒ } |  j ƒ   | j ƒ  } Wd  QX|  j t	 | ƒ d ƒ |  j t	 | ƒ d ƒ d  S(   Ni*   (
   R   R
   R   R   R   RÈ   R¥   R¦   R6   RÌ   (   R2   t   ar1Rã   R¿   R\   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_iterate_eager)  s    c         C@  så   t  t ƒ  d |  j ƒ} t  t ƒ  d |  j ƒ} |  j j t ƒ  ƒ } |  j j t ƒ  | | | g ƒ } |  j t ƒ  | j d d ƒ Wd  QX|  j j t ƒ  ƒ } t ƒ  | _	 |  j j t ƒ  | g ƒ } |  j
 | j d d ƒ ƒ d  S(   NR   R€   gH¯¼šò×z>gš™™™™™¹?(   R¶   R
   R   R   RÈ   RG   R   R—   R   RH   R>   (   R2   RÍ   Rã   t   ar3R¿   t   ar4RÉ   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_join_timeout2  s    !c         C@  s8   |  j  j t ƒ  g  ƒ } |  j t | j ƒ  ƒ g  ƒ d  S(   N(   R   RÈ   R
   RY   RZ   RÚ   (   R2   R¿   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt!   test_iter_native_when_empty_group?  s    c         C@  sW   |  j  ƒ   |  j j ƒ  } Wd  QXt t | ƒ ƒ } |  j | t t |  j ƒ ƒ ƒ d  S(   N(   R¥   R¿   R¦   t   sortedRZ   RY   R   R    (   R2   R\   R”   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_iterate_simpleC  s    c         C@  s)   |  j  t t |  j ƒ ƒ |  j j ƒ d  S(   N(   RY   RZ   RÛ   R¿   R”   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test___iter__I  s    c         C@  s2   |  j  j ƒ  } |  j | t t |  j ƒ ƒ ƒ d  S(   N(   R¿   R—   RY   RZ   R   R    (   R2   t   joined(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt	   test_joinL  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   R>   R¿   Rk   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRp   P  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   RJ   R¿   t   failed(   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_failedS  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   RJ   R¿   t   waiting(   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_waitingV  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   R>   R¿   R`   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR‹   Y  s    c         C@  s&   |  j  |  j j ƒ  t |  j ƒ ƒ d  S(   N(   R6   R¿   t   completed_countR?   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_completed_count\  s    (   RŒ   R   R3   R   RÊ   RË   R“   Rj   RÎ   RÑ   RÒ   R×   RÙ   RÜ   Rà   Ru   Rá   Râ   Rä   Ræ   Ré   Rê   Rì   Rí   Rï   Rp   Rñ   Ró   R‹   Rõ   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRÇ   ´  s6   								
			
																	t   test_pending_AsyncResultc           B@  s   e  Z d  „  Z d „  Z RS(   c         C@  s   |  j  j t ƒ  ƒ |  _ d  S(   N(   R   R   R
   R   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR3   b  s    c         C@  s   |  j  |  j j ƒ d  S(   N(   RO   R   R   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_resulte  s    (   RŒ   R   R3   R÷   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRö   `  s   	t   test_failed_AsyncResultc           B@  s>   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  s‚   d |  _  t |  j d ƒ } t d t j t d ƒ ƒ } t |  j | ƒ |  j j | d ƒ } |  j j	 t
 ƒ  | | g ƒ |  _ d  S(   Ni   i
   t   ts11t   BazR   (   R    R#   R   R   R   R.   R/   R   R   RÈ   R
   R¿   (   R2   RÃ   Rð   t
   failed_res(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR3   k  s    	c         C@  s*   |  j  |  j j ƒ  t |  j ƒ d ƒ d  S(   Ni   (   R6   R¿   Rô   R?   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRõ   s  s    c         @  sR   |  j  ƒ   |  j j ƒ  ‰  Wd  QX‡  f d †  } |  j t ƒ  | ƒ  Wd  QXd  S(   Nc           @  s
   t  ˆ  ƒ S(   N(   RZ   (    (   R\   (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   consumez  s    (   R¥   R¿   R¦   RG   R/   (   R2   Rü   (    (   R\   s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRì   v  s
    c         C@  s'   |  j  t ƒ  |  j j ƒ  Wd  QXd  S(   N(   RG   R/   R¿   R—   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRï   €  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   RJ   R¿   Rk   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRp   „  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   R>   R¿   Rð   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRñ   ‡  s    (   RŒ   R   R3   Rõ   Rì   Rï   Rp   Rñ   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRø   i  s   			
		t   test_pending_Groupc           B@  s>   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  sC   |  j  j t ƒ  |  j  j t ƒ  ƒ |  j  j t ƒ  ƒ g ƒ |  _ d  S(   N(   R   RÈ   R
   R   R¿   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR3     s    	c         C@  s   |  j  |  j j ƒ  d ƒ d  S(   Ni    (   R6   R¿   Rô   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRõ   ’  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   RJ   R¿   R`   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR‹   •  s    c         C@  s   |  j  |  j j ƒ  ƒ d  S(   N(   R>   R¿   Rò   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRó   ˜  s    c         C@  s-   |  j  t ƒ  |  j j d d ƒ Wd  QXd  S(   NR€   gü©ñÒMbP?(   RG   R   R¿   R—   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   x_join›  s    c         C@  s-   |  j  t ƒ  |  j j d d ƒ Wd  QXd  S(   NR€   i   (   RG   R   R¿   R—   (   R2   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   x_join_longerŸ  s    (   RŒ   R   R3   Rõ   R‹   Ró   Rþ   Rÿ   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRý   ‹  s   					t   test_EagerResultc           B@  s5   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  s+   |  j  j d t ƒ d „  ƒ } | |  _ d  S(   NR,   c         S@  s   t  |  | ƒ ‚ d  S(   N(   R/   (   R8   t   y(    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   raising¨  s    (   R   R   R1   R  (   R2   R  (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR3   ¦  s    c         C@  sX   |  j  j d d d g ƒ } |  j t ƒ  | j ƒ  Wd  QX|  j | j d t ƒ ƒ d  S(   NR¡   i   RB   (   R  t   applyRG   R/   t   waitR>   R1   (   R2   R„   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_wait_raises­  s    c         C@  sO   t  d d t j ƒ } | j ƒ  |  j | j t j ƒ |  j | j t j ƒ d  S(   NR8   (   R   R   R   R  R6   R   R;   (   R2   R„   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt	   test_wait³  s    
c         C@  s#   t  d d t j ƒ } | j ƒ  d  S(   NR8   (   R   R   R   R¸   (   R2   R„   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRÑ   ¹  s    c         C@  s2   |  j  j d d d g ƒ } |  j | j ƒ  ƒ d  S(   NR¡   i   (   R  R  RJ   t   revoke(   R2   R„   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_revoke½  s    (   RŒ   R   R3   R  R  RÑ   R  (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR   ¤  s
   				t   test_tuplesc           B@  s,   e  Z d  „  Z d „  Z d „  Z d „  Z RS(   c         C@  sW   |  j  j t ƒ  ƒ } |  j | t | j ƒ  |  j  ƒ ƒ |  j | t | |  j  ƒ ƒ d  S(   N(   R   R   R
   R6   R	   RM   (   R2   R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR$   Ä  s    "c         C@  s‚   |  j  j t ƒ  ƒ } |  j  j t ƒ  ƒ | _ t | j ƒ  |  j  ƒ } |  j | | ƒ |  j | j | j ƒ |  j | j t ƒ d  S(   N(   R   R   R
   RF   R	   RM   R6   R|   (   R2   R8   R  (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_with_parentÉ  s    c         C@  s;   t  ƒ  } t | g  g d |  j ƒ} |  j | j | ƒ d  S(   NR   (   R
   R	   R   R6   R   (   R2   t   uidR8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   test_compatÑ  s    	c         C@  s‚   |  j  j t ƒ  g  t d ƒ D] } |  j  j t ƒ  ƒ ^ q ƒ } |  j | t | j ƒ  |  j  ƒ ƒ |  j | t | |  j  ƒ ƒ d  S(   Ni
   (   R   RÈ   R
   R   R   R6   R	   RM   (   R2   t   _R8   (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyRÇ   Ö  s    	7"(   RŒ   R   R$   R
  R  RÇ   (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyR	  Â  s   			N()   t
   __future__R    t
   contextlibR   t   celeryR   t   celery.exceptionsR   R   t   celery.fiveR   t   celery.resultR   R   R   R	   t   celery.utilsR
   t   celery.utils.serializationR   t   celery.tests.caseR   R   R   R   R   R   R#   R$   RŽ   R³   R¶   Rb   R¹   R¾   RÇ   Rö   Rø   Rý   R   R	  (    (    (    s@   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_result.pyt   <module>   s.   ""		Øj¬	"