ó P'—^c@@sødZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z ddl m Z d d lmZd d lmZd d lmZmZd d lmZd dlmZmZd dlmZmZd dlmZmZmZm Z d dl!m"Z"ddddddgZ#dZ$d„Z%ed„ƒZ&de'fd„ƒYZ(de(fd„ƒYZ)e)Z*de(fd„ƒYZ+de+fd„ƒYZ,de,fd „ƒYZ-de)fd!„ƒYZ.e/d"„Z0e0Z1dS(#sU celery.result ~~~~~~~~~~~~~ Task results/state and groups of results. i(tabsolute_importN(tdeque(tcontextmanager(tcopy(tcached_property(t OrderedDicti(t current_app(tstates(t_set_task_join_will_blockttask_join_will_block(tapp_or_default(tDependencyGraphtGraphFormatter(tIncompleteStreamt TimeoutError(titemstrangetstring_tt monotonic(t deprecatedt ResultBaset AsyncResultt ResultSett GroupResultt EagerResulttresult_from_tuplesÚNever call result.get() within a task! See http://docs.celeryq.org/en/latest/userguide/tasks.html#task-synchronous-subtasks In Celery 3.2 this will result in an exception being raised instead of just being a warning. cC@s#tƒrtjttƒƒndS(N(R twarningstwarntRuntimeWarningt E_WOULDBLOCK(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytassert_will_not_block+s cc@s.tƒ}ttƒz dVWdt|ƒXdS(N(R RtFalse(t reset_value((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytallow_join_result0s    cB@seZdZdZRS(sBase class for all resultsN(t__name__t __module__t__doc__tNonetparent(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR:scB@sîeZdZd%ZeZd%Zd%Zd%d%d%d%d„Zd„Z e Z d„Z d%e d%e d%d„Z d%edeeejejd„ZeZd„Zd„Ze d „Zd „Ze d „Zd „Zd „Zd„Zd„Ze d%d„Zd„Zd„Zd„Z d„Z!d„Z"d„Z#d„Z$d„Z%d„Z&e'd„ƒZ(e)d„ƒZ*e)d„ƒZ+d„Z,d„Z-d„Z.e)d „ƒZ/e/Z0e)d!„ƒZ1e)d"„ƒZ2e2Z3e)d#„ƒZ4e4j5d$„ƒZ4RS(&sbQuery task state. :param id: see :attr:`id`. :keyword backend: see :attr:`backend`. cC@sUt|p|jƒ|_||_|p0|jj|_||_||_d|_dS(N(R tapptidtbackendt task_nameR&R%t_cache(tselfR(R)R*R'R&((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__init__Ss    cC@s(|j}|j|o|jƒfdfS(N(R&R(tas_tupleR%(R,R&((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR.\s cC@s d|_|jj|jƒdS(s;Forget about (and possibly remove the result of) this task.N(R%R+R)tforgetR((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR/as c C@s8|jjj|jd|d|d|d|d|ƒdS(sWSend revoke signal to all workers. Any worker receiving the task, or having reserved the task, *must* ignore it. :keyword terminate: Also terminate the process currently working on the task (if any). :keyword signal: Name of signal to send to process if terminate. Default is TERM. :keyword wait: Wait for replies from workers. Will wait for 1 second by default or you can specify a custom ``timeout``. :keyword timeout: Time in seconds to wait for replies if ``wait`` enabled. t connectiont terminatetsignaltreplyttimeoutN(R'tcontroltrevokeR((R,R0R1R2twaitR4((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR6fs gà?c C@sÍtƒd}|r5|r5|jr5|j}|ƒn|jrX|rQ|jƒn|jS|jj|j d|d|d|d|ƒ} | rÉ|j | ƒ| d} | |krÁ|rÁ| d‚n| dSdS(slWait 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`. :keyword timeout: How long to wait, in seconds, before the operation times out. :keyword propagate: Re-raise exception if the task failed. :keyword interval: Time to wait (in seconds) before retrying to retrieve the result. Note that this does not have any effect when using the amqp result store backend, as it does not use polling. :keyword no_ack: Enable amqp no ack (automatically acknowledge message). If this is :const:`False` then the message will **not be acked**. :keyword follow_parents: Reraise any exception raised by parent task. :raises celery.exceptions.TimeoutError: if `timeout` is not :const:`None` and the result does not arrive within `timeout` seconds. If the remote call raised an exception then that exception will be re-raised. R4tintervalt on_intervaltno_acktstatustresultN( RR%R&t_maybe_reraise_parent_errorR+t maybe_reraiseR<R)twait_forR(t_maybe_set_cache( R,R4t propagateR8R:tfollow_parentstEXCEPTION_STATEStPROPAGATE_STATESR9tmetaR;((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytget{s(         cC@s1x*tt|jƒƒƒD]}|jƒqWdS(N(treversedtlistt_parentsR>(R,tnode((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR=³scc@s(|j}x|r#|V|j}q WdS(N(R&(R,RJ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRI·s  ck@s;x4|jd|ƒD] \}}||j|fVqWdS(s 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 Note that the ``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. Calling :meth:`collect` would return: .. code-block:: python >>> 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] t intermediateN(titerdepsRF(R,RKtkwargst_tR((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytcollect½s*cC@s3d}x&|jƒD]\}}|jƒ}qW|S(N(R%RLRF(R,tvalueRNRO((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytget_leafêsc#@sŠtd|fgƒ}xn|r…|jƒ\}‰|ˆfVˆjƒrp|j‡fd†ˆjpegDƒƒq|stƒ‚qqWdS(Nc3@s|]}ˆ|fVqdS(N((t.0tchild(RJ(s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys ÷s(RR%tpoplefttreadytextendtchildrenR (R,RKtstackR&((RJs//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRLðs   )cC@s|j|jjkS(s¯Returns :const:`True` if the task has been executed. If the task is still running, pending, or is waiting for retry then :const:`False` is returned. (tstateR)t READY_STATES(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRVüscC@s|jtjkS(s8Returns :const:`True` if the task executed successfully.(RZRtSUCCESS(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt successfulscC@s|jtjkS(s)Returns :const:`True` if the task failed.(RZRtFAILURE(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytfailed scC@s"|jtjkr|j‚ndS(N(RZRRDR<(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR> scC@sttd|p!td|jddƒƒ}xF|jd|ƒD]2\}}|j|ƒ|r:|j||ƒq:q:W|S(Nt formattertroottshapetovalRK(R R R(RLtadd_arctadd_edge(R,RKR`tgraphR&RJ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt build_graphs! cC@s t|jƒS(s`str(self) -> self.id`(tstrR((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__str__scC@s t|jƒS(s`hash(self) -> hash(self.id)`(thashR((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__hash__scC@sdjt|ƒj|jƒS(Ns <{0}: {1}>(tformatttypeR"R((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__repr__#scC@s?t|tƒr|j|jkSt|tƒr;||jkStS(N(t isinstanceRR(RtNotImplemented(R,tother((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__eq__&s  cC@s|j|ƒ S(N(Rr(R,Rq((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__ne__-scC@s(|j|j|j|j|j|jƒS(N(t __class__R(R)R*R'R&(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__copy__0scC@s|j|jƒfS(N(Rtt__reduce_args__(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt __reduce__5scC@s|j|j|jd|jfS(N(R(R)R*R%R&(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRv8scC@s d|_dS(N(R%R+(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__del__;scC@s |jƒS(N(Rg(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRf>scC@s |jjS(N(R)tsupports_native_join(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRyBscC@s|jƒjdƒS(NRX(t_get_task_metaRF(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRXFscC@sB|r>|d}|tjks.|tjkr>|j|ƒSn|S(NR;(RR\RDt _set_cache(R,RERZ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR@Js  cC@s2|jdkr+|j|jj|jƒƒS|jS(N(R+R%R@R)t get_task_metaR((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRzQscC@sN|jdƒ}|rAg|D]}t||jƒ^q|dRgRiRkRnRrRsRuRwRvRxRRftpropertyRyRXR@RzR{R<tinfoR~RZR;Rtsetter(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRAsb    3   -                cB@s‘eZdZd!Zd!Zd!d„Zd„Zd„Zd„Z d„Z d„Z d„Z d„Z d „Zd „Zd „Zd „Zd „Zd!ed!ed!d„Zd„Zd„Zeddƒd!edd„ƒZd!edd!ed„Zd!edd!ed„Zd!ded„Zd!edd!ed„Zd„Zd„Zd„Z d„Z!d„Z"e#d„ƒZ$e#d„ƒZ%e#d „ƒZ&RS("sWWorking with more than one result. :param results: List of result instances. cK@s%t|p|jƒ|_||_dS(N(R R'tresults(R,R…R'RM((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR-£scC@s&||jkr"|jj|ƒndS(swAdd :class:`AsyncResult` as a new member of the set. Does nothing if the result is already a member. N(R…tappend(R,R<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytadd§scC@s\t|tƒr$|jj|ƒ}ny|jj|ƒWntk rWt|ƒ‚nXdS(stRemove result from the set; it must be a member. :raises KeyError: if the result is not a member. N(RoRR'RR…tremovet ValueErrortKeyError(R,R<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRˆ°s  cC@s)y|j|ƒWntk r$nXdS(scRemove result from the set if it is a member. If it is not a member, do nothing. N(RˆRŠ(R,R<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytdiscard½s c@s$ˆjj‡fd†|DƒƒdS(sIUpdate set with the union of itself and an iterable with results.c3@s$|]}|ˆjkr|VqdS(N(R…(RStr(R,(s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys ËsN(R…RW(R,R…((R,s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytupdateÈscC@sg|j(dS(s!Remove all results from this set.N(R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytclearÍscC@std„|jDƒƒS(s¤Was all of the tasks successful? :returns: :const:`True` if all of the tasks finished successfully (i.e. did not raise an exception). cs@s|]}|jƒVqdS(N(R](RSR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys Øs(tallR…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR]ÑscC@std„|jDƒƒS(s‰Did any of the tasks fail? :returns: :const:`True` if one of the tasks failed. (i.e., raised an exception) cs@s|]}|jƒVqdS(N(R_(RSR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys ás(tanyR…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR_ÚscC@s"x|jD]}|jƒq WdS(N(R…R>(R,R<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR>ãscC@std„|jDƒƒS(sŒAre any of the tasks incomplete? :returns: :const:`True` if one of the tasks are still waiting for execution. cs@s|]}|jƒ VqdS(N(RV(RSR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys îs(RR…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytwaitingçscC@std„|jDƒƒS(sœDid all of the tasks complete? (either by success of failure). :returns: :const:`True` if all of the tasks has been executed. cs@s|]}|jƒVqdS(N(RV(RSR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys ÷s(RR…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRVðscC@std„|jDƒƒS(sRTask completion count. :returns: the number of tasks completed. cs@s!|]}t|jƒƒVqdS(N(tintR](RSR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys ÿs(tsumR…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytcompleted_countùscC@s"x|jD]}|jƒq WdS(s?Forget about (and possible remove the result of) all the tasks.N(R…R/(R,R<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR/sc C@sN|jjjg|jD]}|j^qd|d|d|d|d|ƒdS(sSend revoke signal to all workers for all tasks in the set. :keyword terminate: Also terminate the process currently working on the task (if any). :keyword signal: Name of signal to send to process if terminate. Default is TERM. :keyword wait: Wait for replies from worker. Will wait for 1 second by default or you can specify a custom ``timeout``. :keyword timeout: Time in seconds to wait for replies if ``wait`` enabled. R0R4R1R2R3N(R'R5R6R…R((R,R0R1R2R7R4RŒ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR6s+ cC@s t|jƒS(N(titerR…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__iter__scC@s |j|S(s`res[i] -> res.results[i]`(R…(R,tindex((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt __getitem__ss3.2s3.3gà?c c@sd}td„|jDƒƒ}xè|r tƒ}xyt|ƒD]k\}}|jƒr‡|jd|ol||d|ƒV|j|ƒq>|jjr>t j |jjƒq>q>Wx|D]}|j |dƒq´Wt j |ƒ||7}|r"||kr"t dƒ‚q"q"WdS(s<Deprecated method, use :meth:`get` with a callback argument.gcs@s$|]}|jt|ƒfVqdS(N(R(R(RSR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys #sR4RAsThe operation timed outN(RR…tsetRRVRFR‡R)tsubpolling_intervalttimetsleeptpopR%R( R,R4RAR8telapsedR…tremovedRR<((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytiterates$        c C@s:|jr|jn|jd|d|d|d|d|ƒS(sÆSee :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. R4RAR8tcallbackR:(Ryt join_nativetjoin(R,R4RAR8R¡R:((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRF7s  c C@s¹tƒtƒ}d}g}x–|jD]‹} d}|rg|tƒ|}|dkrgtdƒ‚qgn| jd|d|d|d|ƒ} |r¤|| j| ƒq&|j| ƒq&W|S(sˆGathers 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`. :keyword timeout: The number of seconds to wait for results before the operation times out. :keyword propagate: If any of the tasks raises an exception, the exception will be re-raised. :keyword interval: 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. :keyword callback: 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 will 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). :keyword no_ack: Automatic message acknowledgement (Note that if this is set to :const:`False` then the messages *will not be acknowledged*). :raises celery.exceptions.TimeoutError: if ``timeout`` is not :const:`None` and the operation takes longer than ``timeout`` seconds. gsjoin operation timed outR4RAR8R:N(RRR%R…RRFR(R†( R,R4RAR8R¡R:t time_startt remainingR…R<RQ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR£Ds"1    cC@sK|j}|stgƒS|jjtd„|Dƒƒd|d|d|ƒS(s1Backend 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. cs@s|]}|jVqdS(N(R((RSRŒ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys šsR4R8R:(R…R•R)tget_manyR™(R,R4R8R:R…((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt iter_nativeŠs   c C@sÝtƒ|rdntd„t|jƒDƒƒ}|r>dn"gtt|ƒƒD] }d^qQ}xs|j|||ƒD]\\} } | d} |r±| dtj kr±| ‚n|rÇ|| | ƒqy| ||| ­sR<R;N( RR%tdictt enumerateR…RtlenR§RRD( R,R4RAR8R¡R:t order_indexRNtaccRRERQ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR¢žs 1"  cC@sd„|jDƒS(Ncs@s<|]2}|jj|jƒr|jtjkr|VqdS(N(R)t is_cachedR(RZRRD(RStres((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys »s(R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt_failed_join_reportºscC@s t|jƒS(N(R«R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__len__¿scC@s#t|tƒr|j|jkStS(N(RoRR…Rp(R,Rq((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRrÂscC@s|j|ƒ S(N(Rr(R,Rq((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRsÇscC@s/djt|ƒjdjd„|jDƒƒƒS(Ns <{0}: [{1}]>s, cs@s|]}|jVqdS(N(R((RSRŒ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys Ìs(RlRmR"R£R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRnÊscC@s|jS(s$Deprecated alias to :attr:`results`.(R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytsubtasksÎscC@s*y|jdjSWntk r%nXdS(Ni(R…Ryt IndexError(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRyÓs cC@s!|jr|jjS|jdjS(Ni(R'R)R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR)ÚsN('R"R#R$R%R'R…R-R‡RˆR‹RRŽR]R_R>R‘RVR”R/RR6R–R˜RRR RFR£R§R¢R°R±RrRsRnR‚R²RyR)(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR˜sJ            E     cB@s­eZdZd Zd Zd d d„Zd d„Zd d„Zd„Z d„Z d„Z e Z d„Z d„Zd „Zd „ZeZed „ƒZed d „ƒZRS(sjLike :class:`ResultSet`, but with an associated id. This type is returned by :class:`~celery.group`, and the deprecated TaskSet, meth:`~celery.task.TaskSet.apply_async` method. It enables inspection of the tasks state and return values as a single entity. :param id: The id of the group. :param results: List of result instances. cK@s ||_tj|||dS(N(R(RR-(R,R(R…RM((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR-ós cC@s|p|jjj|j|ƒS(sæSave group-result for later retrieval using :meth:`restore`. Example:: >>> def save_and_restore(result): ... result.save() ... result = GroupResult.restore(result.id) (R'R)t save_groupR((R,R)((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytsave÷s cC@s |p|jjj|jƒdS(s.Remove this result if it was previously saved.N(R'R)t delete_groupR((R,R)((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytdeletescC@s|j|jƒfS(N(RtRv(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRwscC@s|j|jfS(N(R(R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRv scC@st|jp|jƒS(N(tboolR(R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt__bool__ scC@s5t|tƒr1|j|jko0|j|jkStS(N(RoRR(R…Rp(R,Rq((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRrs"cC@s|j|ƒ S(N(Rr(R,Rq((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRsscC@s5djt|ƒj|jdjd„|jDƒƒƒS(Ns<{0}: {1} [{2}]>s, cs@s|]}|jVqdS(N(R((RSRŒ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pys s(RlRmR"R(R£R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRnscC@s)|jg|jD]}|jƒ^qfS(N(R(R…R.(R,RŒ((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR.scC@s|jS(N(R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRX!scC@s+|p!|jr|jjntjj|ƒS(s&Restore previously saved group result.(R'R)Rt restore_group(R,R(R)((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pytrestore%s$N(R"R#R$R%R(R…R-RµR·RwRvR¹t __nonzero__RrRsRnR.R€R‚RXt classmethodR»(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRßs$         t TaskSetResultcB@sSeZdZdd„Zd„Zed„ƒZed„ƒZej d„ƒZRS(s*Deprecated version of :class:`GroupResult`cK@s3d|kr|d}ntj||||dS(NR²(RR-(R,t taskset_idR…RM((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR-0s  cC@s t|jƒS(s1Deprecated. Use ``iter(self.results)`` instead.(R•R…(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyt itersubtasks7scC@s t|ƒS(sDeprecated: Use ``len(r)``.(R«(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyttotal;scC@s|jS(scompat alias to :attr:`self.id`(R((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR¿@scC@s ||_dS(N(R((R,R(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR¿EsN( R"R#R$R%R-RÀR‚RÁR¿R„(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR¾-s   cB@s¿eZdZdZdd„Zd„Zd„Zd„Zd„Z d„Z de d„Z e Z d„Zd „Zd „Zed „ƒZed „ƒZeZed „ƒZed„ƒZRS(s.Result that we know has already been executed.cC@s(||_||_||_||_dS(N(R(t_resultt_statet _traceback(R,R(t ret_valueRZR~((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR-Ns   cC@s,i|jd6|jd6|jd6|jd6S(NRR<R;R~(R(RÂRÃRÄ(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRzTscC@s|j|jƒfS(N(RtRv(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRwXscC@s|j|j|j|jfS(N(R(RÂRÃRÄ(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRv[scC@s|jƒ\}}||ŒS(N(Rw(R,tclstargs((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRu^scC@stS(N(R(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRVbscK@sB|jƒr|jS|jtjkr>|r7|j‚n|jSdS(N(R]R<RZRRD(R,R4RARM((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRFes   cC@sdS(N((R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR/nscO@stj|_dS(N(RtREVOKEDRÃ(R,RÇRM((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR6qscC@s dj|ƒS(Ns(Rl(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRntscC@s|jS(sThe tasks return value(RÂ(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR<wscC@s|jS(sThe tasks state.(RÃ(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRZ|scC@s|jS(s!The traceback if the task failed.(RÄ(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyR~‚scC@stS(N(R(R,((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRy‡sN(R"R#R$R%R*R-RzRwRvRuRVRRFR7R/R6RnR‚R<RZR;R~Ry(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRJs$         cC@s»t|ƒ}|j}t|tƒs·|\}}|rb|j|g|D]}t||ƒ^qFƒSt|ttfƒr}|n |df\}}|r§t||ƒ}n||d|ƒS|S(NR&( R RRoRRRRHttupleR%(RŒR'tResultR¯tnodesRTR(R&((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyRŒs   &-(2R$t __future__RR›Rt collectionsRt contextlibRRt kombu.utilsRtkombu.utils.compatRtRRRÃRR R'R tdatastructuresR R t exceptionsR RtfiveRRRRtutilsRt__all__RRR!tobjectRRtBaseAsyncResultRRR¾RR%Rtfrom_serializable(((s//tmp/pip-unpacked-wheel-gV1wwp/celery/result.pyts@  "    ÿUÿHNB