P'^c @@s,dZddlmZddlZddlmZddlmZddlmZddl m Z ddl m Z dd l mZmZmZdd lmZmZmZdd lmZdd lmZdd lmZmZmZmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z'ddl(m)Z)ddl*m+Z+ddgZ,edddddddddd d!d" Z-d#Z.d$Z/d%Z0d&Z1d'e2fd(YZ3d)d*Z4e5e5d+Z6de2fd,YZ7d-e8fd.YZ9ee9de2fd/YZ:e:Z;dS(0ss celery.app.task ~~~~~~~~~~~~~~~ Task Implementation: Task request context, and the base task class. i(tabsolute_importN(t ExceptionInfo(t current_app(tstates(t _task_stack(t signature(tMaxRetriesExceededErrortRejecttRetry(tclass_propertytitemstwith_metaclass(tProxy(t EagerResult(t gen_task_nametfun_takes_kwargstuuidt maybe_reraise(t mattrgettert maybe_list(t instantiate(t ErrorMaili(t resolve_all(t_unpickle_task_v2(tappstrtContexttTasktqueuet routing_keytexchangetprioritytexpirest serializert delivery_modet compressiont time_limittsoft_time_limitt immediatet mandatorys$ss,<@task {0.name} bound to other {0.__self__}>s!<@task: {0.name} of {app}{flags}>t _CompatSharedcB@s,eZdZdZdZdZRS(cC@s||_||_dS(N(tnametcons(tselfR(R)((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt__init__2s cC@s t|jS(N(thashR((R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt__hash__6scC@sd|jfS(Ns (R((R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt__repr__9scC@s |j|S(N(R)(R*tapp((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt__call__<s(t__name__t __module__R+R-R.R0(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR'0s   tcC@s |rdjdj|S|S(Ns ({0})s, (tformattjoin(tflagstdefault((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt _strflags@scC@s|dk rt|ng}|jr6|jdnd|sX|jrOtnt}n|j|dt|d|jrt |jndS(Ns v2 compatibleR6R/( tNonetlistt __v2_compat__tappendt_appt R_BOUND_TASKtR_UNBOUND_TASKR4R8R(ttasktfmtR6((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt _reprtaskFscB@seZdZdZdZdZdZdZdZ dZ dZ e Z dZdZdZdZdZdZdZdZeZdZdZdZdZdZdZdZdZddZ dZ!e"dZ#RS(icO@s|j||dS(N(tupdate(R*targstkwargs((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR+lscO@s|jj||S(N(t__dict__RC(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRCoscC@s |jjS(N(RFtclear(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRGrscC@st|||S(N(tgetattr(R*tkeyR7((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytgetuscC@sdjt|S(Ns(R4tvars(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR.xscC@s"|jdkrg|_n|jS(N(t _childrenR9(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytchildren{s N($R1R2R9tlogfiletloglevelthostnametidRDREtretriestetaRtFalsetis_eagertheaderst delivery_infotreply_totcorrelation_idttasksettgrouptchordtutctTruetcalled_directlyt callbacksterrbackst timelimitRLt _protectedR+RCRGRJR.tpropertyRM(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRQs<     tTaskTypecB@s&eZdZiZdZdZRS(sMeta class for tasks. Automatically registers the task in the task registry (except if the :attr:`Task.abstract`` attribute is set). If no :attr:`Task.name` attribute is provided, then the name is generated from the module and class name. c@sttj}jdp$d}jdd}|sRjdt re|Sjddpjdd}t|t r|dkrx<D]%}t |ddr|j }PqqWt j }n|d<jd} | s t ||d<} njdsd d lm} d j|g} | jkrd j| <| t| fd qn|j} | | kr| j|n| | } | j|| jS(NR2t__main__tabstractt autoregisterR=R/R(t _decoratedi(tconnect_on_app_finalizet.ic@s"tjtd|S(NR=(Ret__new__tdict(R/(tattrstbasestclsR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyts(tsuperReRlRJtpopR9R^t isinstanceR RHR=Rt_get_current_objectRt celery._stateRjR5t_creation_countR't_taskstregistertbindt __class__(RpR(RoRntnewt task_moduleRgR/tbaset task_nameRjt unique_namettaskstinstance((RnRoRpR(s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRls<$    "    cC@s t|S(N(RB(Rp((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR.s(R1R2t__doc__RwRlR.(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRes  =cB@seZdZd7ZeZeZeZdZ d7Z d7Z d7Z e ZeZdZd8Zd7Zd7Ze Ze Zd7Zd7Zd7Zd7Zd7Zd7Ze Zd7Zd7Zd9Zd7Z d7Z!d7Z"eZ#d:d;d<d=d>d?d@fZ$d7Z%eZ#e&dZ'e&dZ(e&dZ)e*e)e'Z+e&dZ,e&dZ-dZ.dZ/dZ0dZ1dZ2d7d7d7d7d7d7dZ3d7d7d7d7dZ4d7d7d7e d7d7d7dZ5d7d7d7d7dZ6d Z7d7d!Z8d"Z9d#Z:d$Z;d%Z<d&Z=d'Z>d7d7d7d(Z?d)Z@d*ZAd+ZBd,ZCd-ZDd.ZEd/ZFd0ZGd1ZHd2ZIeJeIZKd3ZLeJd4ZejMd5ZeJd6ZRS(AsTask base class. When called tasks apply the :meth:`run` method. This method must be defined by all tasks (that is unless the :meth:`__call__` method is overridden). scelery.worker.strategy:defaultii<tsend_error_emailstCELERY_SEND_TASK_ERROR_EMAILSR tCELERY_TASK_SERIALIZERt rate_limittCELERY_DEFAULT_RATE_LIMITt track_startedtCELERY_TRACK_STARTEDt acks_latetCELERY_ACKS_LATEt ignore_resulttCELERY_IGNORE_RESULTtstore_errors_even_if_ignoredt#CELERY_STORE_ERRORS_EVEN_IF_IGNOREDcC@s|jt}|_||_|j}d|_xF|jD];\}}t||ddkr8t||||q8q8W|j dkr|j |_ n|s|j ddl m }||_ n|j||S(Ni(t LocalStack(t __bound__R^R=tconfR9t _exec_optionst from_configRHtsetattrtaccept_magic_kwargstannotatetcelery.utils.threadsRt request_stackton_bound(R*R/t was_boundRt attr_namet config_nameR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRzis     cC@sdS(scThis method can be defined to do additional actions when the task class is bound to an app.N((R*R/((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscC@s>|jdkrt|_n|js7|j|jn|jS(N(R=R9RRRz(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt_get_apps   cC@swxpt|jj|D]Y}xPt|D]B\}}|jdr[|j|d|q)t|||q)WqWdS(Nt@i(tresolve_all_annotationsR/t annotationsR t startswitht add_aroundR(R*tdRItvalue((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRs cC@sVt||}t|ddr-|j}n||}||_t|||dS(Nt __wrapped__(RHR9RR(R*tattrtaroundtorigtmeth((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRs    cO@sltj||jz9|jdk r?|j|j||S|j||SWd|jtjXdS(N(Rtpusht push_requestt__self__R9trunt pop_requestRs(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR0s   cC@sFt|j}|r*|tjkr*|nd}t|j|fdfS(N(ttypeR2tsystmodulesR9RR((R*tmod((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt __reduce__s!cO@stddS(s)The body of the task executed by workers.s!Tasks must define the run method.N(tNotImplementedError(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscK@st|j||||S(N(RtStrategy(R*R/tconsumerRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytstart_strategyscO@s|j||S(sAStar argument version of :meth:`apply_async`. Does not support the extra options enabled by :meth:`apply_async`. :param \*args: positional arguments passed on to the task. :param \*\*kwargs: keyword arguments passed on to the task. :returns :class:`celery.result.AsyncResult`: (t apply_async(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytdelays c K@s|j}|jjrF|j||d|p3td|d||S|jdk rt|trj|nt|pvd}|jf|}n|j |j ||d|d|d|d|d|j t |j |S(sApply tasks asynchronously by sending a message. :keyword args: The positional arguments to pass on to the task (a :class:`list` or :class:`tuple`). :keyword kwargs: The keyword arguments to pass on to the task (a :class:`dict`) :keyword countdown: Number of seconds into the future that the task should execute. Defaults to immediate execution. :keyword eta: A :class:`~datetime.datetime` object describing the absolute time and date of when the task should be executed. May not be specified if `countdown` is also supplied. :keyword expires: Either a :class:`int`, describing the number of seconds, or a :class:`~datetime.datetime` object that describes the absolute time and date of when the task should expire. The task will not be executed after the expiration time. :keyword connection: Re-use existing broker connection instead of establishing a new one. :keyword retry: If enabled sending of the task message will be retried in the event of connection loss or failure. Default is taken from the :setting:`CELERY_TASK_PUBLISH_RETRY` setting. Note that you need to handle the producer/connection manually for this to work. :keyword retry_policy: Override the retry policy used. See the :setting:`CELERY_TASK_PUBLISH_RETRY_POLICY` setting. :keyword routing_key: Custom routing key used to route the task to a worker server. If in combination with a ``queue`` argument only used to specify custom routing keys to topic exchanges. :keyword queue: The queue to route the task to. This must be a key present in :setting:`CELERY_QUEUES`, or :setting:`CELERY_CREATE_MISSING_QUEUES` must be enabled. See :ref:`guide-routing` for more information. :keyword exchange: Named custom exchange to send the task to. Usually not used in combination with the ``queue`` argument. :keyword priority: The task priority, a number between 0 and 9. Defaults to the :attr:`priority` attribute. :keyword serializer: A string identifying the default serialization method to use. Can be `pickle`, `json`, `yaml`, `msgpack` or any custom serialization method that has been registered with :mod:`kombu.serialization.registry`. Defaults to the :attr:`serializer` attribute. :keyword compression: A string identifying the compression method to use. Can be one of ``zlib``, ``bzip2``, or any custom compression methods registered with :func:`kombu.compression.register`. Defaults to the :setting:`CELERY_MESSAGE_COMPRESSION` setting. :keyword link: A single, or a list of tasks to apply if the task exits successfully. :keyword link_error: A single, or a list of tasks to apply if an error occurs while executing the task. :keyword producer: :class:~@amqp.TaskProducer` instance to use. :keyword add_to_parent: If set to True (default) and the task is applied while executing another task, then the result will be appended to the parent tasks ``request.children`` attribute. Trailing can also be disabled by default using the :attr:`trail` attribute :keyword publisher: Deprecated alias to ``producer``. :keyword headers: Message headers to be sent in the task (a :class:`dict`) :rtype :class:`celery.result.AsyncResult`: if :setting:`CELERY_ALWAYS_EAGER` is not set, otherwise :class:`celery.result.EagerResult`. Also supports all keyword arguments supported by :meth:`kombu.Producer.publish`. .. note:: If the :setting:`CELERY_ALWAYS_EAGER` setting is set, it will be replaced by a local :func:`apply` call instead. ttask_idtlinkt link_errortproducert result_clsN((RRtCELERY_ALWAYS_EAGERtapplyRRR9Rtttuplet send_taskR(t AsyncResultRmt_get_exec_options( R*RDRERRRRtoptionsR/((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRsc  'c K@s|dkr|jn|}|dkr0|jn|}|dkrK|jn|}|jp]d \}}i |jd6|jd6|jd6|jd6|j d6|d6|d6|j d6|j d 6}|j |ri|d 6n |j pi|j|||d ||S( NRRRtgroup_idR\R$R#RXRVRR(NN(R9trequestRDRERbRQR`RaR[R\RXRVRCRWtsubtask( R*RRDRERt extra_optionst limit_hardt limit_softR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytsubtask_from_request@s"       #c K@s|j} | jd} |d kr+|jn|}| jrYt|pStdd n| rx|d krx|j}n| j} |j | ||d|d|d| |} |d k r | |kr |rt|n|j dj |j | j | j| jntd|d|p|} | r>| jj| Sy| jWn%tk rs}t|d tnX|r| n| S( sh Retry the task. :param args: Positional arguments to retry with. :param kwargs: Keyword arguments to retry with. :keyword exc: Custom exception to report when the max restart limit has been exceeded (default: :exc:`~@MaxRetriesExceededError`). If this argument is set and retry is called while an exception was raised (``sys.exc_info()`` is set) it will attempt to reraise the current exception. If no exception was raised it will raise the ``exc`` argument provided. :keyword countdown: Time in seconds to delay the retry for. :keyword eta: Explicit time and date to run the retry at (must be a :class:`~datetime.datetime` instance). :keyword max_retries: If set, overrides the default retry limit for this execution. Changes to this parameter do not propagate to subsequent task retry attempts. A value of :const:`None`, means "use the default", so if you want infinite retries you would have to set the :attr:`max_retries` attribute of the task to :const:`None` first. :keyword time_limit: If set, overrides the default time limit. :keyword soft_time_limit: If set, overrides the default soft time limit. :keyword \*\*options: Any extra options to pass on to meth:`apply_async`. :keyword throw: If this is :const:`False`, do not raise the :exc:`~@Retry` exception, that tells the worker to mark the task as being retried. Note that this means the task will be marked as failed if the task raises an exception, or successful if it returns. :raises celery.exceptions.Retry: To tell the worker that the task has been re-sent for retry. This always happens, unless the `throw` keyword argument has been explicitly set to :const:`False`, and is considered normal operation. **Example** .. code-block:: python >>> from imaginary_twitter_lib import Twitter >>> from proj.celery import app >>> @app.task(bind=True) ... def tweet(self, auth, message): ... twitter = Twitter(oauth=auth) ... try: ... twitter.post_status_update(message) ... except twitter.FailWhale as exc: ... # Retry in 5 minutes. ... raise self.retry(countdown=60 * 5, exc=exc) Although the task will never return above as `retry` raises an exception to notify the worker, we use `raise` in front of the retry to convey that the rest of the block will not be executed. isTask can be retriedt countdownRSRRs(Can't retry {0}[{1}] args:{2} kwargs:{3}texctwhentrequeueN(RRRR9t max_retriesR_RRtdefault_retry_delayRURRR4R(RQRDRERRJRt ExceptionRRT(R*RDRERtthrowRSRRRRRRRUtStret((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytretryVs>?        $ c @s_ddlm}|j}|p%d}|jdk rP|jft|}n|pYi}|jdpqt}|jdd} |jd|j dd} |j |j } i |d6| d6t d6|jd d 6|jd dd 6t |d 6t |d 6|jd d 6it d6d6} |jri| j d6|d6| d6t d6|jd d 6|jd dd 6it d6d6} t| j| tfdt| D}|j|nd}|| |||d|jd| d| \}}t|tr+|j|j}}n|dkr@tjn|j}t|||d|S(sExecute this task locally, by blocking until the task returns. :param args: positional arguments passed on to the task. :param kwargs: keyword arguments passed on to the task. :keyword throw: Re-raise task exceptions. Defaults to the :setting:`CELERY_EAGER_PROPAGATES_EXCEPTIONS` setting. :rtype :class:`celery.result.EagerResult`: i(teager_trace_taskRRRt"CELERY_EAGER_PROPAGATES_EXCEPTIONSRRQRURNROR`RaRVRWRt task_retriest task_is_eagerc3@s-|]#\}}|kr||fVqdS(N((t.0RItval(tsupported_keys(s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pys s R/Rt propagatet traceback(N(tcelery.app.traceRRRR9RRJRteitherRsRxR(R^RRRRRmR RCRtRt exceptionRRtSUCCESStstateR (R*RDRERRRRR/RRRRR@Rtdefault_kwargst extend_withttbtretvaltinfoR((Rs1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRsP          cK@s(|jj|d|jd|j|S(smGet AsyncResult instance for this kind of task. :param task_id: Task id to get result for. tbackendR(RRRR((R*RRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscO@s&|jd|jt||||S(sReturn :class:`~celery.signature` object for this task, wrapping arguments and execution options for a single task invocation.R/(t setdefaultR/R(R*RDtstarargst starkwargs((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR scO@s|j||S(s!``.s(*a, **k) -> .subtask(a, k)``(R(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytsscO@s|j||dtS(s2``.si(*a, **k) -> .subtask(a, k, immutable=True)``t immutable(RR^(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytsiscC@s/ddlm}||j||d|jS(s<Creates a :class:`~celery.canvas.chunks` task for this task.i(tchunksR/(tceleryRRR/(R*tittnR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscC@s,ddlm}||j|d|jS(s8Creates a :class:`~celery.canvas.xmap` task from ``it``.i(txmapR/(RRRR/(R*RR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytmapscC@s,ddlm}||j|d|jS(s<Creates a :class:`~celery.canvas.xstarmap` task from ``it``.i(txstarmapR/(RRRR/(R*RR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytstarmap#sc K@sJ|j}|jjjd|j }|j|d|j|SWdQXdS(NRPR(RR/teventstdefault_dispatcherRPtsendRQ(R*ttype_tfieldstreqR((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt send_event(s cC@s5|dkr|jj}n|jj|||dS(sUpdate task state. :keyword task_id: Id of the task to update, defaults to the id of the current task :keyword state: New state (:class:`str`). :keyword meta: State metadata (:class:`dict`). N(R9RRQRt store_result(R*RRtmeta((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt update_state-s cC@sdS(sSuccess handler. Run by the worker if the task executes successfully. :param retval: The return value of the task. :param task_id: Unique id of the executed task. :param args: Original arguments for the executed task. :param kwargs: Original keyword arguments for the executed task. The return value of this handler is ignored. N((R*RRRDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt on_success<s cC@sdS(sRetry handler. This is run by the worker when the task is to be retried. :param exc: The exception sent to :meth:`retry`. :param task_id: Unique id of the retried task. :param args: Original arguments for the retried task. :param kwargs: Original keyword arguments for the retried task. :keyword einfo: :class:`~billiard.einfo.ExceptionInfo` instance, containing the traceback. The return value of this handler is ignored. N((R*RRRDREteinfo((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyton_retryKscC@sdS(sError handler. This is run by the worker when the task fails. :param exc: The exception raised by the task. :param task_id: Unique id of the failed task. :param args: Original arguments for the task that failed. :param kwargs: Original keyword arguments for the task that failed. :keyword einfo: :class:`~billiard.einfo.ExceptionInfo` instance, containing the traceback. The return value of this handler is ignored. N((R*RRRDRER((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt on_failure]scC@sdS(sHandler called after the task returns. :param status: Current task state. :param retval: Task return value/exception. :param task_id: Unique id of the task. :param args: Original arguments for the task. :param kwargs: Original keyword arguments for the task. :keyword einfo: :class:`~billiard.einfo.ExceptionInfo` instance, containing the traceback (if any). The return value of this handler is ignored. N((R*tstatusRRRDRER((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt after_returnpscK@s?|jr;t|dd r;|j||j||ndS(Ntdisable_error_emails(RRHR9RR(R*tcontextRRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytsend_error_emails cC@s#|jr|jjj|n|S(N(ttrailRRMR<(R*tresult((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt add_trails cO@s|jjt||dS(N(RRR(R*RDRE((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscC@s|jjdS(N(RRs(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscC@st||jrtntS(s `repr(task)`(RBRt R_SELF_TASKt R_INSTANCE(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR.scC@sA|jj}|dkr=|jdkr6t|_n|jS|S(sGet current request object.N(RttopR9t_default_requestR(R*R((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyt _get_requests   cC@s(|jdkr!t||_n|jS(N(RR9textract_exec_options(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscC@s#|j}|dkr|jjS|S(N(t_backendR9R/R(R*R((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRs   cC@s ||_dS(N(R(R*R((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRscC@s |jjS(N(R{R1(R*((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyR1sNi((RR(R R(RR(RR(RR(RR(RR(NR1R2RR9t __trace__RTR;RRRRR=R(R^RgRRRRRRt send_eventsRRR R#R$RRhRRtthrowsRRRRRRt classmethodRzRRR R/RRR0RRRRRRRRRRRRRRRRRRRR R RRRRR.RRdRRtsetter(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pyRs        p   l=                  (<Rt __future__RRtbilliard.einfoRRRRRvRt celery.canvasRtcelery.exceptionsRRRt celery.fiveR R R t celery.localR t celery.resultR t celery.utilsRRRRtcelery.utils.functionalRRtcelery.utils.importsRtcelery.utils.mailRRRRtregistryRtutilsRt__all__RR>R?RRtobjectR'R8R9RBRRReRtBaseTask(((s1/tmp/pip-unpacked-wheel-gV1wwp/celery/app/task.pytsJ "    2M