o wvXj@sdZddlmZmZddlZddlZddlmZmZddl m Z ddl m Z ddl m Z ddlmZmZmZd d lmZmZd d lmZmZd d lmZd d lmZmZmZd dlmZm Z m!Z!m"Z"m#Z#d dl$m%Z%d dl&m'Z'm(Z(d dl)m*Z*zddl+Z+Wn e,ydZ+YnwdZ-dZ.ddZ/e ddZ0e ddZ1Gddde2Z3ej4e!Gddde3Z5ej4e!Gddde3Z6ej4e!Gd d!d!e6Z7ej4e!Gd"d#d#e5Z8d&d$d%Z9dS)'z3Task results/state and results for groups of tasks.)absolute_importunicode_literalsN) OrderedDictdeque)contextmanager)copy)cached_property)Thenablebarrierpromise) current_appstates)_set_task_join_will_blocktask_join_will_block)app_or_default)ImproperlyConfiguredIncompleteStream TimeoutError)items monotonicpython_2_unicode_compatiblerangestring_t) deprecated)DependencyGraphGraphFormatter) parse_iso8601) ResultBase AsyncResult ResultSet GroupResult EagerResultresult_from_tuplez|Never call result.get() within a task! See http://docs.celeryq.org/en/latest/userguide/tasks.html#task-synchronous-subtasks cCstrttdSN)r RuntimeError E_WOULDBLOCKr'r'J/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/result.pyassert_will_not_block)sr)cc0t}tdz dVWt|dSt|wNFrr reset_valuer'r'r(allow_join_result. r/ccr*NTr,r-r'r'r(denied_join_result8r0r2c@seZdZdZdZdS)rzBase class for results.N)__name__ __module__ __qualname____doc__parentr'r'r'r(rBsrc @s4eZdZdZdZeZdZdZ   dfddZe ddZ e j ddZ dgd d Z d d Z d dZddZ  dhddZdddddddddejejf ddZeZddZddZdiddZddZdidd Zd!d"Zd#d$Zd%d&Zd'd(Zdjd)d*ZeZ d+d,Z!dkd-d.Z"d/d0Z#d1d2Z$d3d4Z%d5d6Z&d7d8Z'd9d:Z(d;d<Z)d=d>Z*d?d@Z+e,dAdBZ-e dCdDZ.e dEdFZ/dGdHZ0dIdJZ1dKdLZ2dMdNZ3e dOdPZ4e4Z5e dQdRZ6e dSdTZ7e7Z8e dUdVZ9e9j dWdVZ9e dXdYZ:e dZd[Z;e d\d]Ze dbdcZ?e dddeZ@dS)lrzxQuery task state. Arguments: id (str): See :attr:`id`. backend (Backend): See :attr:`backend`. NcCsd|dur tdt|t|p|j|_||_|p|jj|_||_t|j dd|_ d|_ d|_ dS)Nz&AsyncResult requires valid id, not {0}TweakF) ValueErrorformattyperappidbackendr7r _on_fulfilledon_ready_cache_ignored)selfr>r? task_namer=r7r'r'r(__init__^s  zAsyncResult.__init__cCst|dr|jSdS)z+If True, task result retrieval is disabled.rCF)hasattrrCrDr'r'r(ignoredls zAsyncResult.ignoredcCs ||_dS)z%Enable/disable task result retrieval.N)rC)rDvaluer'r'r(rIss FcCs|jj||d|j||S)Nr8)r?add_pending_resultrAthenrDcallbackon_errorr9r'r'r(rLxszAsyncResult.thencCs|j||Sr$r?remove_pending_resultrDresultr'r'r(r@|s zAsyncResult._on_fulfilledcCs|j}|j|o |fdfSr$)r7r>as_tuple)rDr7r'r'r(rTszAsyncResult.as_tuplecCs(d|_|jr |j|j|jdS)z/Forget the result of this task and its parents.N)rBr7forgetr?r>rHr'r'r(rUs zAsyncResult.forgetcCs |jjj|j|||||ddS)aSend revoke signal to all workers. Any worker receiving the task, or having reserved the task, *must* ignore it. Arguments: terminate (bool): Also terminate the process currently working on the task (if any). signal (str): Name of signal to send to process if terminate. Default is TERM. wait (bool): Wait for replies from workers. The ``timeout`` argument specifies the seconds to wait. Disabled by default. timeout (float): Time in seconds to wait for replies when ``wait`` is enabled. ) connection terminatesignalreplytimeoutN)r=controlrevoker>rDrVrWrXwaitrZr'r'r(r\s zAsyncResult.revokeT?c Cs|jrdS| r tt} |r|r|jrt|jdd} ||r&| ||jr4|r1|j|d|jS|j ||j j |||| ||||dS)aWait until task is ready, and return its result. Warning: Waiting for tasks within a task may lead to deadlocks. Please read :ref:`task-synchronous-subtasks`. Warning: Backends use resources to store and transmit results. To ensure that resources are released, you must eventually call :meth:`~@AsyncResult.get` or :meth:`~@AsyncResult.forget` on EVERY :class:`~@AsyncResult` instance returned after calling a task. Arguments: timeout (float): How long to wait, in seconds, before the operation times out. propagate (bool): Re-raise exception if the task failed. interval (float): Time to wait (in seconds) before retrying to retrieve the result. Note that this does not have any effect when using the RPC/redis result store backends, as they don't use polling. no_ack (bool): Enable amqp no ack (automatically acknowledge message). If this is :const:`False` then the message will **not be acked**. follow_parents (bool): Re-raise any exception raised by parent tasks. disable_sync_subtasks (bool): Disable tasks to wait for sub tasks this is the default configuration. CAUTION do not enable this unless you must. Raises: celery.exceptions.TimeoutError: if `timeout` isn't :const:`None` and the result does not arrive within `timeout` seconds. Exception: If the remote call raised an exception then that exception will be re-raised in the caller process. NTr8)rN)rZinterval on_intervalno_ack propagaterN on_message) rIr)r r7_maybe_reraise_parent_errorrLrB maybe_throwrSr?rKwait_for_pending) rDrZrcr`rbfollow_parentsrNrdradisable_sync_subtasksEXCEPTION_STATESPROPAGATE_STATES _on_intervalr'r'r(gets0*   zAsyncResult.getcCs"tt|D]}|qdSr$)reversedlist_parentsrfrDnoder'r'r(res z'AsyncResult._maybe_reraise_parent_errorccs$|j}|r|V|j}|sdSdSr$r7rqr'r'r(rps  zAsyncResult._parentscks2|j|dD]\}}||jdi|fVqdS)aCollect results as they return. Iterator, like :meth:`get` will wait for the task to complete, but will also follow :class:`AsyncResult` and :class:`ResultSet` returned by the task, yielding ``(result, value)`` tuples for each result in the tree. An example would be having the following tasks: .. code-block:: python from celery import group from proj.celery import app @app.task(trail=True) def A(how_many): return group(B.s(i) for i in range(how_many))() @app.task(trail=True) def B(i): return pow2.delay(i) @app.task(trail=True) def pow2(i): return i ** 2 .. code-block:: pycon >>> from celery.result import ResultBase >>> from proj.tasks import A >>> result = A.delay(10) >>> [v for v in result.collect() ... if not isinstance(v, (ResultBase, tuple))] [0, 1, 4, 9, 16, 25, 36, 49, 64, 81] Note: The ``Task.trail`` option must be enabled so that the list of children is stored in ``result.children``. This is the default but enabled explicitly for illustration. Yields: Tuple[AsyncResult, Any]: tuples containing the result instance of the child task, and the return value of that task.  intermediateNr'iterdepsrm)rDrukwargs_Rr'r'r(collects.zAsyncResult.collectcCs"d}|D]\}}|}q|Sr$rv)rDrJryrzr'r'r(get_leaf#s zAsyncResult.get_leafc#shtd|fg}|r2|\}|fVr)|fddjp$gDn|s.t|s dSdS)Nc3s|]}|fVqdSr$r'.0childrrr'r( 0z'AsyncResult.iterdeps..)rpopleftreadyextendchildrenr)rDrustackr7r'rr(rw)s    zAsyncResult.iterdepscCs|j|jjvS)zReturn :const:`True` if the task has executed. If the task is still running, pending, or is waiting for retry then :const:`False` is returned. )stater? READY_STATESrHr'r'r(r5szAsyncResult.readycC |jtjkS)z7Return :const:`True` if the task executed successfully.)rrSUCCESSrHr'r'r( successful= zAsyncResult.successfulcCr)z(Return :const:`True` if the task failed.)rrFAILURErHr'r'r(failedArzAsyncResult.failedcOs|jj|i|dSr$)rAthrowrDargsrxr'r'r(rEszAsyncResult.throwcCsn|jdur |n|j}|d|d|d}}}|tjvr+|r+|||||dur5||j||S)NstatusrS traceback)rB_get_task_metarmrrkr_to_remote_tracebackr>)rDrcrNcacherrJtbr'r'r(rfHs  zAsyncResult.maybe_throwcCs2|rtdur|jjjrtj|SdSdSdSr$)tblibr=conftask_remote_tracebacks Traceback from_string as_traceback)rDrr'r'r(rSs z AsyncResult._to_remote_tracebackcCsLt|p t|jddd}|j|dD]\}}|||r#|||q|S)Noval)rootshape) formatterrt)rrr>rwadd_arcadd_edge)rDrurgraphr7rrr'r'r( build_graphWs  zAsyncResult.build_graphcC t|jSz`str(self) -> self.id`.strr>rHr'r'r(__str__a zAsyncResult.__str__cCrz`hash(self) -> hash(self.id)`.hashr>rHr'r'r(__hash__erzAsyncResult.__hash__cCsdt|j|jS)Nz <{0}: {1}>)r;r<r3r>rHr'r'r(__repr__izAsyncResult.__repr__cCs.t|tr |j|jkSt|tr||jkStSr$) isinstancerr>rNotImplementedrDotherr'r'r(__eq__ls    zAsyncResult.__eq__cC||}|tur dS| Sr1rrrDrresr'r'r(__ne__s zAsyncResult.__ne__cCs||j|jd|j|jSr$) __class__r>r?r=r7rHr'r'r(__copy__wszAsyncResult.__copy__cC|j|fSr$r__reduce_args__rHr'r'r( __reduce__|zAsyncResult.__reduce__cCs|j|jdd|jfSr$)r>r?r7rHr'r'r(rrzAsyncResult.__reduce_args__cCs|jdur |j|dSdS)z9Cancel pending operations when the instance is destroyed.NrPrHr'r'r(__del__s zAsyncResult.__del__cCs|Sr$)rrHr'r'r(rzAsyncResult.graphcCs|jjSr$)r?supports_native_joinrHr'r'r(rrz AsyncResult.supports_native_joincC|dS)NrrrmrHr'r'r(rzAsyncResult.childrencCs:|r|d}|tjvr||j|}|||S|S)Nr)rr _set_cacher?meta_from_decodedrA)rDmetardr'r'r(_maybe_set_caches  zAsyncResult._maybe_set_cachecCs$|jdur||j|jS|jSr$)rBrr? get_task_metar>rHr'r'r(rs zAsyncResult._get_task_metacKst|gSr$)iterrrDrxr'r'r( _iter_metarzAsyncResult._iter_metacs.|d}|rfdd|D|d<|_|S)Nrcsg|]}t|jqSr')r#r=r}rHr'r(  z*AsyncResult._set_cache..)rmrB)rDrrr'rHr(rs   zAsyncResult._set_cachecC |dS)zTask return value. Note: When the task has been executed, this contains the return value. If the task raised an exception, this will be the exception instance. rSrrHr'r'r(rSs zAsyncResult.resultcCr)z#Get the traceback of a failed task.rrrHr'r'r(rszAsyncResult.tracebackcCr)aThe tasks current state. Possible values includes: *PENDING* The task is waiting for execution. *STARTED* The task has been started. *RETRY* The task is to be retried, possibly because of failure. *FAILURE* The task raised an exception, or has exceeded the retry limit. The :attr:`result` attribute then contains the exception raised by the task. *SUCCESS* The task executed successfully. The :attr:`result` attribute then contains the tasks return value. rrrHr'r'r(rs zAsyncResult.statecC|jS)zCompat. alias to :attr:`id`.r>rHr'r'r(task_idzAsyncResult.task_idcC ||_dSr$r)rDr>r'r'r(rrcCr)NnamerrHr'r'r(rrzAsyncResult.namecCr)NrrrHr'r'r(rrzAsyncResult.argscCr)NrxrrHr'r'r(rxrzAsyncResult.kwargscCr)NworkerrrHr'r'r(rrzAsyncResult.workercCs*|d}|rt|tjst|S|S)zUTC date and time. date_done)rrmrdatetimer)rDrr'r'r(rszAsyncResult.date_donecCr)NretriesrrHr'r'r(rrzAsyncResult.retriescCr)NqueuerrHr'r'r(rrzAsyncResult.queue)NNNNr+NFNFN)F)TN)FN)Ar3r4r5r6r=rr>r?rFpropertyrIsetterrLr@rTrUr\rrjrkrmr^rerpr{r|rwrrrrrf maybe_reraiserrrrrrrrrrrrrrrrrrrrSinforrrrrrrxrrrrr'r'r'r(rIs      E 1                      rc@speZdZdZdZdZdIddZddZddZd d Z d d Z d dZ ddZ ddZ ddZdJddZeZddZddZddZddZ  dKd!d"Zd#d$Zd%d&Zed'd(dLd*d+Z )  dMd,d-Z )  dMd.d/ZdNd0d1Z  dOd2d3Z    dPd4d5Zd6d7Z d8d9Z!d:d;Z"dd?Z$d@dAZ%e&dBdCZ'e&dDdEZ(e(j)dFdEZ(e&dGdHZ*dS)Qr zpA collection of results. Arguments: results (Sequence[AsyncResult]): List of result instances. NcKsL||_||_t|fd|_|pt||_|jr$|jt|jdddSdS)N)rTr8)_appresultsr rAr _on_fullrL _on_ready)rDrr= ready_barrierrxr'r'r(rFszResultSet.__init__cCs4||jvr|j||jr|j|dSdSdS)zvAdd :class:`AsyncResult` as a new member of the set. Does nothing if the result is already a member. N)rappendraddrRr'r'r(rs  z ResultSet.addcCs|jjr |dSdSr$)r?is_asyncrArHr'r'r(r(s zResultSet._on_readycCs@t|tr |j|}z |j|WdStyt|w)z~Remove result from the set; it must be a member. Raises: KeyError: if the result isn't a member. N)rrr=rrremover:KeyErrorrRr'r'r(r,s   zResultSet.removecCs&z||WdStyYdSw)zbRemove result from the set if it is a member. Does nothing if it's not a member. N)rrrRr'r'r(discard9s  zResultSet.discardcsjfdd|DdS)z Extend from iterable of results.c3s|] }|jvr|VqdSr$rr~rrHr'r(rEsz#ResultSet.update..N)rr)rDrr'rHr(updateCszResultSet.updatecCsg|jdd<dS)z!Remove all results from this set.NrrHr'r'r(clearGszResultSet.clearcCtdd|jDS)zReturn true if all tasks successful. Returns: bool: true if all of the tasks finished successfully (i.e. didn't raise an exception). cs|]}|VqdSr$)rr~rSr'r'r(rRrz'ResultSet.successful..allrrHr'r'r(rKzResultSet.successfulcCr)zReturn true if any of the tasks failed. Returns: bool: true if one of the tasks failed. (i.e., raised an exception) csrr$)rrr'r'r(r[rz#ResultSet.failed..anyrrHr'r'r(rTrzResultSet.failedTcCs|jD] }|j||dqdS)N)rNrc)rrf)rDrNrcrSr'r'r(rf]s zResultSet.maybe_throwcCr)zReturn true if any of the tasks are incomplete. Returns: bool: true if one of the tasks are still waiting for execution. css|]}| VqdSr$rrr'r'r(risz$ResultSet.waiting..rrHr'r'r(waitingbrzResultSet.waitingcCr)zDid all of the tasks complete? (either by success of failure). Returns: bool: true if all of the tasks have been executed. csrr$rrr'r'r(rqrz"ResultSet.ready..rrHr'r'r(rkzResultSet.readycCr)zaTask completion count. Returns: int: the number of tasks completed. css|] }t|VqdSr$)intrrr'r'r(rysz,ResultSet.completed_count..)sumrrHr'r'r(completed_countsrzResultSet.completed_countcCs|jD]}|qdS)z?Forget about (and possible remove the result of) all the tasks.N)rrUrRr'r'r(rU{s  zResultSet.forgetFcCs*|jjjdd|jD|||||ddS)a[Send revoke signal to all workers for all tasks in the set. Arguments: terminate (bool): Also terminate the process currently working on the task (if any). signal (str): Name of signal to send to process if terminate. Default is TERM. wait (bool): Wait for replies from worker. The ``timeout`` argument specifies the number of seconds to wait. Disabled by default. timeout (float): Time in seconds to wait for replies when the ``wait`` argument is enabled. cSsg|]}|jqSr'rrr'r'r(rz$ResultSet.revoke..)rVrZrWrXrYN)r=r[r\rr]r'r'r(r\s zResultSet.revokecCrr$)rrrHr'r'r(__iter__ zResultSet.__iter__cCs |j|S)z`res[i] -> res.results[i]`.r)rDindexr'r'r( __getitem__rzResultSet.__getitem__z4.0z5.0r_c csd}tdd|jD}|r^t}t|D]%\}}|r0|j|o%|||dV||q|jjr;t |jjq|D]}| |dq>t |||7}|rZ||krZt d|sdSdS)zrrr'r'r(rsz$ResultSet.iterate..)rZrcNzThe operation timed out) rrsetrrrmrr?subpolling_intervaltimesleeppopr) rDrZrcr`elapsedrremovedrrSr'r'r(iterates.    zResultSet.iteratec Cs&|jr|jn|j||||||||dS)zSee :meth:`join`. This is here for API compatibility with :class:`AsyncResult`, in addition it uses :meth:`join_native` if available for the current result backend. )rZrcr`rNrbrdrira)r join_nativejoin) rDrZrcr`rNrbrdrirar'r'r(rms  z ResultSet.getc  Cs|rtt} d} |durtdg} |jD].} d} |r,|t| } | dkr,td| j| |||||d} |r@|| j| q| | q| S)aGather the results of all tasks as a list in order. Note: This can be an expensive operation for result store backends that must resort to polling (e.g., database). You should consider using :meth:`join_native` if your backend supports it. Warning: Waiting for tasks within a task may lead to deadlocks. Please see :ref:`task-synchronous-subtasks`. Arguments: timeout (float): The number of seconds to wait for results before the operation times out. propagate (bool): If any of the tasks raises an exception, the exception will be re-raised when this flag is set. interval (float): Time to wait (in seconds) before retrying to retrieve a result from the set. Note that this does not have any effect when using the amqp result store backend, as it does not use polling. callback (Callable): Optional callback to be called for every result received. Must have signature ``(task_id, value)`` No results will be returned by this function if a callback is specified. The order of results is also arbitrary when a callback is used. To get access to the result object for a particular id you'll have to generate an index first: ``index = {r.id: r for r in gres.results.values()}`` Or you can create new result objects on the fly: ``result = app.AsyncResult(task_id)`` (both will take advantage of the backend cache anyway). no_ack (bool): Automatic message acknowledgment (Note that if this is set to :const:`False` then the messages *will not be acknowledged*). disable_sync_subtasks (bool): Disable tasks to wait for sub tasks this is the default configuration. CAUTION do not enable this unless you must. Raises: celery.exceptions.TimeoutError: if ``timeout`` isn't :const:`None` and the operation takes longer than ``timeout`` seconds. Nz,Backend does not support on_message callbackr zjoin operation timed out)rZrcr`rbrari)r)rrrrrmr>r)rDrZrcr`rNrbrdrira time_start remainingrrSrJr'r'r(rs0/  zResultSet.joincC|j||Sr$rArLrMr'r'r(rL rzResultSet.thencCs|jj||||||dS)a0Backend optimized version of :meth:`iterate`. .. versionadded:: 2.2 Note that this does not support collecting the results for different task types using different backends. This is currently only supported by the amqp, Redis and cache result backends. )rZr`rbrdra)r? iter_native)rDrZr`rbrdrar'r'r(rs  zResultSet.iter_nativec Cs|rt|r dn ddt|jD} |rdn ddtt|D} ||||||D]5\} } t| trCg} | D] }| | q8n| d} |rR| dt j vrR| |rZ|| | q+| | | | <q+| S)a-Backend optimized version of :meth:`join`. .. versionadded:: 2.2 Note that this does not support collecting the results for different task types using different backends. This is currently only supported by the amqp, Redis and cache result backends. NcSsi|]\}}|j|qSr'r)r~irSr'r'r( 1rz)ResultSet.join_native..cSsg|]}dqSr$r')r~ryr'r'r(r4sz)ResultSet.join_native..rSr) r) enumeraterrlenrrrorrmrrk)rDrZrcr`rNrbrdrari order_indexaccrrrJchildren_resultr'r'r(r!s*   zResultSet.join_nativecKs.dd|jjdd|jDfddi|DS)Ncss|]\}}|VqdSr$r')r~ryrr'r'r(rFrz'ResultSet._iter_meta..cSsh|]}|jqSr'rrr'r'r( Grz'ResultSet._iter_meta..max_iterationsr )r?get_manyrrr'r'r(rEs  zResultSet._iter_metacCsdd|jDS)Ncss.|]}|j|jr|jtjvr|VqdSr$)r? is_cachedr>rrrk)r~rr'r'r(rKs  z0ResultSet._failed_join_report..rrHr'r'r(_failed_join_reportJzResultSet._failed_join_reportcCrr$)rrrHr'r'r(__len__OrzResultSet.__len__cCst|tr |j|jkStSr$)rr rrrr'r'r(rRs  zResultSet.__eq__cCrr1rrr'r'r(rWrzResultSet.__ne__cCs$dt|jddd|jDS)Nz <{0}: [{1}]>, cs|]}|jVqdSr$rrr'r'r(r]z%ResultSet.__repr__..)r;r<r3rrrHr'r'r(r[s zResultSet.__repr__cCs$z|jdjWStyYdSwNr)rr IndexErrorrHr'r'r(r_s  zResultSet.supports_native_joincCs,|jdur|jr|jdjnt|_|jSr,)rrr=r _get_current_objectrHr'r'r(r=fs z ResultSet.appcCrr$)r)rDr=r'r'r(r=mrcCs|jr|jjS|jdjSr,)r=r?rrHr'r'r(r?qszResultSet.backendNNr1r)NTr_)NTr_NTNTNr+)Nr_TNN)NTr_NTNNT)+r3r4r5r6rrrFrrrrrrrrrfrrrrrUr\rr rCallablerrmrrLrrrr&r(rrrrrr=rr?r'r'r'r(r sr           J  $   r c@seZdZdZdZdZd!ddZddZd"ddZd"d d Z d d Z d dZ ddZ e Z ddZddZddZddZddZddZeddZed#dd ZdS)$r!azLike :class:`ResultSet`, but with an associated id. This type is returned by :class:`~celery.group`. It enables inspection of the tasks state and return values as a single entity. Arguments: id (str): The id of the group. results (Sequence[AsyncResult]): List of result instances. parent (ResultBase): Parent result of this group. NcKs$||_||_tj||fi|dSr$)r>r7r rF)rDr>rr7rxr'r'r(rFszGroupResult.__init__cCs|j|t|dSr$)r?rQr rrHr'r'r(rs zGroupResult._on_readycCs|p|jj|j|S)zSave group-result for later retrieval using :meth:`restore`. Example: >>> def save_and_restore(result): ... result.save() ... result = GroupResult.restore(result.id) )r=r? save_groupr>rDr?r'r'r(saveszGroupResult.savecCs|p|jj|jdS)z.Remove this result if it was previously saved.N)r=r? delete_groupr>r2r'r'r(deleteszGroupResult.deletecCrr$rrHr'r'r(rrzGroupResult.__reduce__cCs |j|jfSr$)r>rrHr'r'r(r zGroupResult.__reduce_args__cCst|jp|jSr$)boolr>rrHr'r'r(__bool__r'zGroupResult.__bool__cCsFt|tr|j|jko|j|jko|j|jkSt|tr!||jkStSr$)rr!r>rr7rrrr'r'r(rs      zGroupResult.__eq__cCrr1rrr'r'r(rrzGroupResult.__ne__cCs(dt|j|jddd|jDS)Nz<{0}: {1} [{2}]>r)csr*r$rrr'r'r(rr+z'GroupResult.__repr__..)r;r<r3r>rrrHr'r'r(rs zGroupResult.__repr__cCrrrrHr'r'r(rrzGroupResult.__str__cCrrrrHr'r'r(rrzGroupResult.__hash__cCs&|j|jo |jfdd|jDfS)NcSsg|]}|qSr')rTrr'r'r(rsz(GroupResult.as_tuple..)r>r7rTrrHr'r'r(rTszGroupResult.as_tuplecCrr$rrHr'r'r(rszGroupResult.childrencCs.|p t|jts |jnt}|p|j}||S)z&Restore previously saved group result.)rr=rr r? restore_group)clsr>r?r=r'r'r(restores   zGroupResult.restore)NNNr$r/)r3r4r5r6r>rrFrr3r5rrr8 __nonzero__rrrrrrTrr classmethodr;r'r'r'r(r!vs,     r!c@seZdZdZd%ddZd&ddZdd Zd d Zd d ZddZ ddZ  d'ddZ e Z ddZ ddZddZeddZeddZedd ZeZed!d"Zed#d$ZdS)(r"z.Result that we know has already been executed.NcCs.||_||_||_||_t|_||dSr$)r>_result_state _tracebackr rA)rDr> ret_valuerrr'r'r(rFs zEagerResult.__init__FcCrr$rrMr'r'r(rLrzEagerResult.thencCrr$)rBrHr'r'r(rszEagerResult._get_task_metacCrr$rrHr'r'r(rrzEagerResult.__reduce__cCs|j|j|j|jfSr$r>r>r?r@rHr'r'r(rrzEagerResult.__reduce_args__cCs|\}}||Sr$)r)rDr:rr'r'r(rs zEagerResult.__copy__cCdSr1r'rHr'r'r(rzEagerResult.readyTcKsN|rt|r |jS|jtjvr%|r"t|jtr|jt|j|jSdSr$)r)rrSrrrkr Exception)rDrZrcrirxr'r'r(rms  zEagerResult.getcCsdSr$r'rHr'r'r(rUrDzEagerResult.forgetcOs tj|_dSr$)rREVOKEDr?rr'r'r(r\r6zEagerResult.revokecCs d|S)Nz)r;rHr'r'r(rrzEagerResult.__repr__cCs|j|j|j|jdS)N)rrSrrrBrHr'r'r(rBs zEagerResult._cachecCr)zThe tasks return value.)r>rHr'r'r(rS rzEagerResult.resultcCr)zThe tasks state.)r?rHr'r'r(r%rzEagerResult.statecCr)z!The traceback if the task failed.)r@rHr'r'r(r+rzEagerResult.tracebackcCrCr+r'rHr'r'r(r0sz EagerResult.supports_native_joinr$r+)NTT)r3r4r5r6rFrLrrrrrrmr^rUr\rrrBrSrrrrr'r'r'r(r"s6        r"cstj}t|ts?|\}}t|ttfr|n|df\}}|r&t|}|dur9j|fdd|D|dS|||dS|S)zDeserialize result from tuple.Ncsg|]}t|qSr')r#r}r=r'r(rCsz%result_from_tuple..rs)rrrrrotupler#r!)rr=Resultrnodesr>r7r'rGr(r#5s   r#r$):r6 __future__rrrr collectionsrr contextlibrrkombu.utils.objectsrviner r r r rr?rrr=r exceptionsrrrfiverrrrrutilsr utils.graphrr utils.iso8601rr ImportError__all__r&r)r/r2objectrregisterrr r!r"r#r'r'r'r(s`           @nfU