ó
P'—^c           @@  sn  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 m Z 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 „  Z 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 S(   i    (   t   absolute_import(   t   datetimet	   timedelta(   t   Queue(   t   Task(   t   Retry(   t   itemst   ranget   string_t(   t   EagerResult(   t   uuid(   t   parse_iso8601(   t   AppCaset   depends_on_current_appt   patchc          O@  s   t  S(   N(   t   True(   t   argst   kwargs(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   return_True   s    c         K@  s   t  d |  j ƒ ‚ d  S(   Ns   %s error(   t	   Exceptiont	   __class__(   t   selfR   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   raise_exception   s    t   MockApplyTaskc           B@  s&   e  Z e Z d  Z d „  Z d „  Z RS(   i    c         C@  s   | | S(   N(    (   R   t   xt   y(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   run   s    c         O@  s   |  j  d 7_  d  S(   Ni   (   t   applied(   R   R   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   apply_async"   s    (   t   __name__t
   __module__R   t   abstractR   R   R   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyR      s   	t	   TasksCasec           B@  s   e  Z d  „  Z RS(   c         C@  sx  |  j  j d t ƒ t ƒ |  _ |  j  j d t d d d t ƒ d d „ ƒ } | |  _ |  j  j d t ƒ d „  ƒ } | |  _ |  j  j d t d d	 d
 d d t ƒ d d  t d „ ƒ } | |  _	 |  j  j d t d d	 d
 d d t ƒ d „  ƒ } | |  _
 |  j  j d t d d	 d
 d d t d t ƒ d d „ ƒ } | |  _ |  j  j d t d d	 d
 d d t ƒ d d „ ƒ } | |  _ d  S(   Nt   sharedt   bindt   counti    i   c         S@  s   |  j  | p d 7_  |  j  S(   Ni   (   R#   (   R   t   increment_by(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   increment_counter+   s    c           S@  s   t  d ƒ ‚ d  S(   Nt   foo(   t   KeyError(    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   raising1   s    t   max_retriesi   t
   iterationsc         S@  s}   |  j  d 7_  | d  k r$ |  j n | } t |  j ƒ s? t ‚ |  j j } | ra | | k ra | S|  j d d d | ƒ ‚ d  S(   Ni   t	   countdowni    R)   (   R*   t   NoneR)   t   reprt   requestt   AssertionErrort   retriest   retry(   R   t   arg1t   arg2t   kwargR)   t   caret   rmaxR0   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt
   retry_task6   s    c         [@  s;   |  j  d 7_  |  j j d k r% d S|  j d d ƒ ‚ d  S(   Ni   i   i*   R+   i    (   R*   R.   R0   R1   (   R   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   retry_task_noargsC   s    t   basec         S@  sA   |  j  d 7_  |  j j } | d k r+ | S|  j d d ƒ ‚ d  S(   Ni   i   R+   i    (   R*   R.   R0   R1   (   R   R2   R3   R4   R0   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   retry_task_mockapplyM   s
    c         [@  s   |  j  d 7_  |  j j } | d k r/ | | Sy t d ƒ ‚ Wn; t k
 r| } | j d | ƒ |  j d d d | ƒ ‚ n Xd  S(   Ni   i   s   Elaine Marie BenesR4   R+   i    t   exc(   R*   R.   R0   t   MyCustomExceptiont   updateR1   (   R   R2   R3   R4   R   R0   R;   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   retry_task_customexcX   s    (   t   appt   taskt   FalseR   t   mytaskR   R%   R(   R,   R7   R8   R   R:   R>   (   R   R%   R(   R7   R8   R:   R>   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   setup(   s$    		$
	0		$(   R   R   RC   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyR    &   s   R<   c           B@  s   e  Z d  Z RS(   s   Random custom exception.(   R   R   t   __doc__(    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyR<   h   s   t   test_task_retriesc           B@  sG   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  s–   d |  j  _ d |  j  _ |  j  j d d g ƒ |  j |  j  j d ƒ d |  j  _ d |  j  _ |  j  j d d g i d d 6ƒ |  j |  j  j d ƒ d  S(	   Ni   i    iÿ   iÿÿ  i   i
   R)   i   (   R7   R)   R*   t   applyt   assertEqual(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt
   test_retryn   s     c         C@  sK   d |  j  _ d |  j  _ |  j  j d t ƒ j ƒ  |  j |  j  j d ƒ d  S(   Ni   i    t	   propagatei   (   R8   R)   R*   RF   R   t   getRG   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_retry_no_argsy   s    c      	   C@  s‰   |  j  j ƒ  zg |  j t ƒ R d d  l } y | j ƒ  Wn t k
 rM n X|  j  j d d d g d d  ƒ Wd  QXWd  |  j  j	 ƒ  Xd  S(   Ni    R   i   R   (
   R:   t   push_requestt   assertRaisesR   t   syst	   exc_cleart   AttributeErrorR1   R,   t   pop_request(   R   RN   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_retry_kwargs_can_be_empty   s    )c         C@  s	  |  j  j ƒ  zç t |  j  j _ t d ƒ } zI |  j  j d d d g d i d d 6d | d t ƒ |  j |  j  j ƒ Wd  d |  j  _ Xz_ |  j	 t
 ƒ 7 |  j  j d d d g d i d d 6d | d t ƒ Wd  QX|  j |  j  j ƒ Wd  d |  j  _ XWd  |  j  j ƒ  Xd  S(	   Nt   bazR   i   R   i    t   task_retriesR;   t   throw(   R:   RL   RA   R.   t   called_directlyR   R1   t
   assertTrueR   RM   R   R   RQ   (   R   R;   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_retry_not_eagerŒ   s$    c         C@  sR   d |  j  _ d |  j  _ |  j  j d d g i d d 6ƒ |  j |  j  j d ƒ d  S(   Ni   i    iÿ   iÿÿ  i   R4   i   (   R>   R)   R*   RF   RG   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_retry_with_kwargs¥   s     c         C@  st   d |  j  _ d |  j  _ |  j  j d d g i d d 6ƒ } |  j t ƒ  | j ƒ  Wd  QX|  j |  j  j d ƒ d  S(   Ni   i    iÿ   iÿÿ  i   R4   i   (   R>   R)   R*   RF   RM   R<   RJ   RG   (   R   t   result(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt    test_retry_with_custom_exception«   s    	c         C@  sð   d |  j  _ d |  j  _ |  j  j d d g i t d 6ƒ } |  j |  j  j ƒ  | j ƒ  Wd  QX|  j |  j  j d ƒ d |  j  _ d |  j  _ |  j  j d d g i t d 6ƒ } |  j |  j  j ƒ  | j ƒ  Wd  QX|  j |  j  j d ƒ d  S(   Ni   i    iÿ   iÿÿ  R5   i   i   (	   R7   R)   R*   RF   RA   RM   t   MaxRetriesExceededErrorRJ   RG   (   R   RZ   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_max_retries_exceededµ   s    ""(	   R   R   RH   RK   RR   RX   RY   R[   R]   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyRE   l   s   						
t   test_canvas_utilsc           B@  s5   e  Z d  „  Z d „  Z d „  Z d „  Z d „  Z RS(   c         C@  s3   |  j  |  j j ƒ  ƒ |  j  |  j j ƒ  j ƒ d  S(   N(   RW   R7   t   sit	   immutable(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_siÇ   s    c         C@  s&   |  j  |  j j t d ƒ d ƒ ƒ d  S(   Nid   i
   (   RW   R7   t   chunksR   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_chunksË   s    c         C@  s#   |  j  |  j j t d ƒ ƒ ƒ d  S(   Nid   (   RW   R7   t   mapR   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_mapÎ   s    c         C@  s#   |  j  |  j j t d ƒ ƒ ƒ d  S(   Nid   (   RW   R7   t   starmapR   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_starmapÑ   s    c         C@  s   |  j  j d d d i  ƒ d  S(   Ni   (    (   R7   t
   on_success(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_on_successÔ   s    (   R   R   Ra   Rc   Re   Rg   Ri   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyR^   Å   s
   				t
   test_tasksc           B@  s¿   e  Z d  „  Z e d „  ƒ Z d „  Z e 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 RS(   c         C@  s   |  j  j ƒ  S(   N(   R?   t   now(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyRk   Ú   s    c         C@  s]   d d  l  } |  j j d t ƒ d „  ƒ } |  j | j | j | ƒ ƒ | j j | j ƒ d  S(   Ni    R!   c           S@  s   d  S(   N(    (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   xxxá   s    (	   t   pickleR?   R@   R   t   assertIst   loadst   dumpst   taskst   name(   R   Rm   Rl   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_unpickle_taskÝ   s    c         C@  sK   t  ƒ  } |  j j | ƒ } |  j | j |  j j ƒ |  j | j | ƒ d  S(   N(   R
   R7   t   AsyncResultRG   t   backendt   id(   R   t   task_idRZ   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_AsyncResultæ   s    	c         K@  s-  | j  d j d d g ƒ } | j ƒ  } |  j | d | j ƒ |  j | d | ƒ | j d i  ƒ }	 | r¬ |  j | j d ƒ t ƒ t | j d ƒ ƒ }
 |  j |
 t ƒ n  | ró |  j | j d ƒ t ƒ t | j d ƒ ƒ }
 |  j |
 t ƒ n  x3 t	 | ƒ D]% \ } } |  j |	 j | ƒ | ƒ q Wd  S(	   Ni    t   acceptRm   Rv   R@   R   t   etat   expires(
   t   queuesRJ   t   decodeRG   Rv   t   assertIsInstanceR   R   R   R   (   R   t   consumert   presultt	   task_namet   test_etat   test_expiresR   t	   next_taskt	   task_datat   task_kwargst   to_datetimet   arg_namet	   arg_value(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   assertNextTaskDataEqualì   s    c         @  sC   d t  f ‡  f d †  ƒ  Y} ˆ  j t ƒ  | ƒ  j ƒ  Wd  QXd  S(   Nt   IncompleteTaskc           @  s   e  Z ˆ  j Z d  Z RS(   s   c.unittest.t.itask(   R   R   R?   Rr   (    (   R   (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyR‹      s   	(   R   RM   t   NotImplementedErrorR   (   R   R‹   (    (   R   s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_incomplete_task_clsþ   s    c         C@  s-   |  j  t ƒ  |  j j g  d ƒ Wd  QXd  S(   Nt   str(   RM   t
   ValueErrorR%   R   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt#   test_task_kwargs_must_be_dictionary  s    c         C@  s-   |  j  t ƒ  |  j j d i  ƒ Wd  QXd  S(   NRŽ   (   RM   R   R%   R   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_task_args_must_be_list  s    c         C@  sù  |  j  |  j t ƒ |  j |  j j ƒ  ƒ |  j t |  j ƒ d ƒ |  j |  j ƒ  d ƒ |  j j ƒ  Œ} |  j j j	 | ƒ } |  j
 t ƒ  | j d d ƒ Wd  QX| j ƒ  |  j | j d j ƒ  ƒ |  j j j	 | d t d ƒ g ƒ|  j j ƒ  } |  j | | |  j j ƒ |  j j d t d d ƒ ƒ } |  j | | |  j j d d ƒ|  j j |  j j d t d d	 ƒ ƒ} |  j | | |  j j d d	 ƒ|  j j d t d d ƒ d
 |  j ƒ  t d d ƒ d |  j ƒ  t d d ƒ ƒ } |  j | | |  j j d d d t d t ƒ|  j j d t d d ƒ d d d d ƒ } |  j | | |  j j d d d t d t ƒ| j ƒ  |  j j ƒ  |  j | j ƒ  d ƒ |  j | j d j ƒ  ƒ |  j | j ƒ  ƒ |  j j j | j  d d  ƒ|  j | j ƒ  ƒ Wd  QXd  S(   Ns   Task class is callable()s!   Task class runs run() when calledR&   i    R|   R   Rr   s   George Costanzas   Elaine M. BenesRz   t   daysi   R{   i   R‚   Rƒ   R+   i
   i   RZ   ("   R~   RB   R   RW   R   t   callableR?   t   connection_or_acquiret   amqpt   TaskConsumerRM   RŒ   t   receivet   purget   assertIsNoneR|   RJ   R   t   delayRŠ   Rr   R   t   dictt	   send_taskRk   R   R   RG   t   assertFalset
   successfulRu   t   mark_as_doneRv   R,   (   R   t   connR   R€   t   presult2t   sresult(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_regular_task  sR    
"
c         C@  s)   t  |  j _ |  j d t |  j ƒ ƒ d  S(   Ns   v2 compatible(   R   RB   t   __v2_compat__t   assertInR-   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_repr_v2_compatP  s    c         C@  sW   |  j  j d d d t ƒ d „  ƒ } |  j | j ƒ  j ƒ  d ƒ |  j | ƒ  d ƒ d  S(   Nt   __self__i*   R!   c         S@  s   |  S(   N(    (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   tawselfV  s    (   R?   R@   RA   RG   RF   RJ   (   R   R¨   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_apply_with_selfT  s    $c         C@  sz   |  j  j ƒ  zX |  j  j } d | _ |  j | j d ƒ d ƒ |  j | j d d ƒ d ƒ | j ƒ  Wd  |  j  j ƒ  Xd  S(   Ni    R&   t   bari$   (   RB   RL   R.   R&   RG   RJ   t   clearRQ   (   R   R.   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_context_get^  s    	c         C@  sT   |  j  d t |  j j j ƒ ƒ d  |  j j j _ |  j  d t |  j j j ƒ ƒ d  S(   Ns   class Task oft   unbound(   R¥   R-   RB   R?   R   R,   t   _app(   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_task_class_repri  s    c         C@  s&   d  |  j _ |  j j |  j j ƒ d  S(   N(   R,   RB   t   accept_magic_kwargsR"   R?   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_bind_no_magic_kwargsn  s    c         C@  sg   t  d ƒ U } i d d 6g | _ |  j j d t ƒ d „  ƒ } | j ƒ  |  j | j d ƒ Wd  QXd  S(   Ns'   celery.app.task.resolve_all_annotationst   BARt   FOOR!   c           S@  s   d  S(   N(    (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyR@   v  s    (   R   t   return_valueR?   R@   RA   t   annotateRG   R³   (   R   t   annoR@   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_annotater  s
    
c         C@  sm   |  j  j ƒ  zK |  j  j ƒ  |  j  j _ |  j  j d d d d i  d  ƒ |  j  j j ƒ  Wd  |  j  j ƒ  Xd  S(   Nt   SUCCESSg      ð?t   foobar(    (	   RB   RL   t   sR.   t   chordt   after_returnR,   R«   RQ   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_after_return|  s    c         C@  sJ   |  j  j ƒ  5 } t |  j  j _ |  j |  j  j j | ƒ j ƒ Wd  QXd  S(   N(	   R?   t
   connectionR   t   conft   CELERY_SEND_TASK_SENT_EVENTRW   R•   t   TaskProducert   send_sent_event(   R   R    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_send_task_sent_event…  s    c         C@  s  |  j  j d t ƒ d „  ƒ } | j ƒ  zÎ t ƒ  } | j | d i d d 6ƒ |  j | j | ƒ j d ƒ |  j	 | j | ƒ j
 i d d 6ƒ | | j _ | j d d d i d d 6ƒ |  j | j | ƒ j d ƒ |  j	 | j | ƒ j
 i d d 6ƒ Wd  | j ƒ  Xd  S(	   NR!   c           S@  s   d  S(   N(    (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   yyyŒ  s    t   FROBULATINGt   baazt   foozt   statet   FROBUZATINGt   meta(   R?   R@   RA   RL   R
   t   update_stateRG   Rt   t   statust   assertDictEqualRZ   R.   Rv   RQ   (   R   RÄ   t   tid(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_update_stateŠ  s    
	#'c         C@  s8   |  j  j d t ƒ d „  ƒ } |  j d t | ƒ ƒ d  S(   NR!   c           S@  s   d  S(   N(    (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   task_test_repr   s    RÐ   (   R?   R@   RA   R¥   R-   (   R   RÐ   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt	   test_reprž  s    c         C@  s2   |  j  j d t ƒ d „  ƒ } |  j | j ƒ d  S(   NR!   c           S@  s   d  S(   N(    (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   yyy2¨  s    (   R?   R@   RA   RW   R   (   R   RÒ   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_has___name__¦  s    (   R   R   Rk   R   Rs   Rx   RA   RŠ   R   R   R‘   R£   R¦   R©   R¬   R¯   R±   R·   R½   RÃ   RÏ   RÑ   RÓ   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyRj   Ø   s&   								A		
				
					t   test_apply_taskc           B@  s#   e  Z d  „  Z d „  Z d „  Z RS(   c         C@  s-   |  j  t ƒ  |  j j d t ƒ Wd  QXd  S(   NRU   (   RM   R'   R(   RF   R   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   test_apply_throw±  s    c         C@  s6   t  |  j j _ |  j t ƒ  |  j j ƒ  Wd  QXd  S(   N(   R   R?   R¿   t"   CELERY_EAGER_PROPAGATES_EXCEPTIONSRM   R'   R(   RF   (   R   (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt2   test_apply_with_CELERY_EAGER_PROPAGATES_EXCEPTIONSµ  s    c         C@  sL  d |  j  _ |  j  j ƒ  } |  j | t ƒ |  j | j ƒ  d ƒ |  j  j d d g ƒ } |  j | j ƒ  d ƒ |  j  j d i d d 6ƒ } |  j | j ƒ  d ƒ |  j | j ƒ  ƒ |  j | j	 ƒ  ƒ |  j t
 | ƒ j d	 ƒ ƒ |  j j ƒ  } |  j | j	 ƒ  ƒ |  j | j ƒ  ƒ |  j | j ƒ |  j t ƒ  | j ƒ  Wd  QXd  S(
   Ni    i   R   i   R   i   R$   i   s   <EagerResult:(   R%   R#   RF   R~   R	   RG   RJ   RW   Rž   t   readyR-   t
   startswithR(   R   t	   tracebackRM   R'   (   R   t   et   f(    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt
   test_applyº  s"    (   R   R   RÕ   R×   RÝ   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyRÔ   ¯  s   		N("   t
   __future__R    R   R   t   kombuR   t   celeryR   t   celery.exceptionsR   t   celery.fiveR   R   R   t   celery.resultR	   t   celery.utilsR
   t   celery.utils.timeutilsR   t   celery.tests.caseR   R   R   R   R   R   R    R   R<   RE   R^   Rj   RÔ   (    (    (    s?   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/tasks/test_tasks.pyt   <module>   s$   		BY×