HEX

File: //usr/local/lib/python3.9/site-packages/celery/app/__pycache__/task.cpython-39.pyc
a

X>h��
@s~dZddlZddlmZmZddlmZddlmZddl	m
Z
ddlmZm
Z
ddlmZdd	lmZmZmZdd
lmZmZmZmZmZddlmZddlmZmZdd
lm Z ddl!m"Z"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z,ddl-m.Z.ddl/m0Z0dZ1e"dddddddddd d!d"�Z2d#Z3d$Z4d%Z5e6Z7d/d'd(�Z8d0d)d*�Z9Gd+d,�d,�Z:e j;j<Gd-d.�d.��Z=e=Z>dS)1z=Task implementation: request context and the task base class.�N)�
ExceptionInfo�ExceptionWithTraceback)�
serialization)�OperationalError)�uuid)�current_app�states)�_task_stack)�_chain�group�	signature)�Ignore�ImproperlyConfigured�MaxRetriesExceededError�Reject�Retry)�class_property)�EagerResult�denied_join_result)�abstract)�mattrgetter�
maybe_list)�instantiate)�gethostname)�raise_with_context�)�resolve_all)�_unpickle_task_v2)�appstr)�Context�Task�queue�routing_key�exchange�priority�expires�
serializerZ
delivery_mode�compression�
time_limit�soft_time_limitZ	immediate�	mandatoryz$<class {0.__name__} of {app}{flags}>z<unbound {0.__name__}{flags}>z!<@task: {0.name} of {app}{flags}>�cCs|rd�d�|��S|S)Nz ({})z, )�format�join)�flags�default�r0�9/usr/local/lib/python3.9/site-packages/celery/app/task.py�	_strflags+sr2cCs^|durt|�ng}|jr$|�d�nd|s:|jr6tnt}|j|t|�|jrVt|j�ndd�S)Nz
v2 compatible)r.�app)	�list�
__v2_compat__�append�_app�R_BOUND_TASK�R_UNBOUND_TASKr,r2r)�task�fmtr.r0r0r1�	_reprtask1s�r<c@s�eZdZdZdZdZdZdZdZdZ	dZ
dZdZdZ
dZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dd�Z'dd	�Z(d
d�Z)dd
�Z*ddd�Z+dd�Z,dd�Z-e.dd��Z/dS)rz&Task request variables (Task.request).NrTFcOs0|j|i|��|jdur,|j|i|��|_dS�N)�update�headers�_get_custom_headers��self�args�kwargsr0r0r1�__init__cs
zContext.__init__cOsXi}|j|i|��htj���d�d�d�d�d�}|D]}|�|d�q:|sTdS|S)N�langr:ZargsreprZ
kwargsreprr')r>r�__dict__�keys�pop)rBrCrDr?Zcelery_keys�keyr0r0r1r@hs"zContext._get_custom_headerscOs|jj|i|��Sr=)rGr>rAr0r0r1r>rszContext.updatecCs
|j��Sr=)rG�clear�rBr0r0r1rKusz
Context.clearcCst|||�Sr=)�getattr)rBrJr/r0r0r1�getxszContext.getcCsdt|��d�S)Nz
<Context: �>)�varsrLr0r0r1�__repr__{szContext.__repr__cCs�|jpd\}}|j|j|j|j|j|j|j|j|j	|j
|j|||j|j
|j|j|jd�}t|d�r�t|d�r�|jdur�|jdur�|j|d<|j��D]\}}|||<q�|S)N)NN)�task_id�root_id�	parent_id�group_id�group_index�shadow�chord�chain�link�
link_errorr%r)r(r?�retries�reply_to�replaced_task_nesting�origin�stamps�stamped_headers)�	timelimit�idrSrTrrVrWrXrY�	callbacks�errbacksr%r?r\r]r^r_�hasattrr`ra�items)rBZ
limit_hardZ
limit_softZexecution_options�k�vr0r0r1�as_execution_options~s4�

zContext.as_execution_optionscCs|jdurg|_|jSr=)�	_childrenrLr0r0r1�children�s
zContext.children)N)0�__name__�
__module__�__qualname__�__doc__rkZ
_protectedrCrd�called_directlyrYrXZcorrelation_id�
delivery_infore�etar%rrVr?�hostnamerc�
ignore_result�is_eagerrD�logfile�loglevelr_rTZ
propertiesr\r]r^rSrWZtasksetrb�utcrar`rEr@r>rKrNrQrj�propertyrlr0r0r0r1r<sZ

rc
@s0eZdZdZdZdZeZeZdZdZ	dZ
dZdZdZ
dZdZdZdZdZdZdZdZdZdZdZdZdZdZd	ZdZdZd
ZdZ dZ!dZ"dZ#dZ$dZ%dZ&e'dd
��Z(e'dd��Z)e'dd��Z*e+e*e(�Z,e'dd��Z-e'dd��Z.dd�Z/dd�Z0dd�Z1dd�Z2dd�Z3d]d d!�Z4d"d#�Z5d^d$d%�Z6e6Z7d_d&d'�Z8d`d(d)�Z9d*d+�Z:dad,d-�Z;e;Z<d.d/�Z=d0d1�Z>d2d3�Z?d4d5�Z@d6d7�ZAdbd8d9�ZBd:d;�ZCdcd<d=�ZDddd>d?�ZEd@dA�ZFdBdC�ZGdDdE�ZHdFdG�ZIdHdI�ZJdJdK�ZKdLdM�ZLdNdO�ZMdPdQ�ZNdRdS�ZOdTdU�ZPeQeP�ZRdVdW�ZSeQdXdY��ZejTdZdY��ZeQd[d\��ZdS)er z�Task base class.

    Note:
        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).
    NFzcelery.worker.strategy:defaultzcelery.worker.request:Request��Tr0i)
)r&�task_serializer)�
rate_limitZtask_default_rate_limit)r$Ztask_default_priority)�
track_startedZtask_track_started)�	acks_lateZtask_acks_late)�acks_on_failure_or_timeoutZtask_acks_on_failure_or_timeout)�reject_on_worker_lostZtask_reject_on_worker_lost)ruZtask_ignore_result)Zstore_eager_resultZtask_store_eager_result)�store_errors_even_if_ignoredZ!task_store_errors_even_if_ignoredcCs�|jd}|_||_|j}d|_|jdur2|j|_|jD](\}}t||d�dur8t||||�q8|s�|�	�ddl
m}|�|_|�
|�|S)NTr)�
LocalStack)�	__bound__r7�conf�
_exec_options�typingZ
strict_typing�from_configrM�setattr�annotateZcelery.utils.threadsr��
request_stack�on_bound)�clsr3Z	was_boundr��	attr_nameZconfig_namer�r0r0r1�bindWs

z	Task.bindcCsdS)z�Called when the task is bound to an app.

        Note:
            This class method can be defined to do additional actions when
            the task class is bound to an app.
        Nr0)r�r3r0r0r1r�qsz
Task.on_boundcCs(|jdurt|_|js"|�|j�|jSr=)r7rr�r�)r�r0r0r1�_get_appzs

z
Task._get_appcCsVt|jj|�D]B}|��D]4\}}|�d�rB|�|dd�|�qt|||�qqdS)N�@r)�resolve_all_annotationsr3�annotationsrg�
startswith�
add_aroundr�)r��drJ�valuer0r0r1r��s

z
Task.annotatecCs:t||�}t|dd�r|j}||�}||_t|||�dS)N�__wrapped__)rMr�r�)r��attrZaround�orig�methr0r0r1r��s
zTask.add_aroundcOsRt�|�|j||d�z"|j|i|��W|��t��S|��t��0dS)N)rCrD)r	�push�push_request�run�pop_requestrIrAr0r0r1�__call__�s
��z
Task.__call__cCs0t|�j}|r|tjvr|nd}t|j|fdfSr=)�typern�sys�modulesr�name)rB�modr0r0r1�
__reduce__�s
zTask.__reduce__cOstd��dS)z)The body of the task executed by workers.z!Tasks must define the run method.N)�NotImplementedErrorrAr0r0r1r��szTask.runcKst|j|||fi|��Sr=)r�Strategy)rBr3ZconsumerrDr0r0r1�start_strategy�szTask.start_strategycOs|�||�S)ahStar argument version of :meth:`apply_async`.

        Does not support the extra options enabled by :meth:`apply_async`.

        Arguments:
            *args (Any): Positional arguments passed on to the task.
            **kwargs (Any): Keyword arguments passed on to the task.
        Returns:
            celery.result.AsyncResult: Future promise.
        )�apply_asyncrAr0r0r1�delay�sz
Task.delayc
Ks�|jr |jr |j|jkr td��|jrZz
|j}	WntyBYn0|	|pLdi|pTi��|jrx|pt|�|�|||�}n|p�|�|||�}|��}
|r�t	|
fi|��n|
}|�
d|j�|jr�|�
d|j�|�
�}|jj�r�|�|��n}|�d�}
|
du�r|j�r|j}
n|jj}
||f}t�||
�\}}}tj||||gd�\}}Wd�n1�s^0Yt��4|j||f|�p�t�||d�|��Wd�S1�s�0Yn*|j|j||f|||||j||d	�|��SdS)
aApply tasks asynchronously by sending a message.

        Arguments:
            args (Tuple): The positional arguments to pass on to the task.

            kwargs (Dict): The keyword arguments to pass on to the task.

            countdown (float): Number of seconds into the future that the
                task should execute.  Defaults to immediate execution.

            eta (~datetime.datetime): Absolute time and date of when the task
                should be executed.  May not be specified if `countdown`
                is also supplied.

            expires (float, ~datetime.datetime): Datetime or
                seconds in the future for the task should expire.
                The task won't be executed after the expiration time.

            shadow (str): Override task name used in logs/monitoring.
                Default is retrieved from :meth:`shadow_name`.

            connection (kombu.Connection): Reuse existing broker connection
                instead of acquiring one from the connection pool.

            retry (bool): If enabled sending of the task message will be
                retried in the event of connection loss or failure.
                Default is taken from the :setting:`task_publish_retry`
                setting.  Note that you need to handle the
                producer/connection manually for this to work.

            retry_policy (Mapping): Override the retry policy used.
                See the :setting:`task_publish_retry_policy` setting.

            time_limit (int): If set, overrides the default time limit.

            soft_time_limit (int): If set, overrides the default soft
                time limit.

            queue (str, kombu.Queue): The queue to route the task to.
                This must be a key present in :setting:`task_queues`, or
                :setting:`task_create_missing_queues` must be
                enabled.  See :ref:`guide-routing` for more
                information.

            exchange (str, kombu.Exchange): Named custom exchange to send the
                task to.  Usually not used in combination with the ``queue``
                argument.

            routing_key (str): 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.

            priority (int): The task priority, a number between 0 and 9.
                Defaults to the :attr:`priority` attribute.

            serializer (str): Serialization method to use.
                Can be `pickle`, `json`, `yaml`, `msgpack` or any custom
                serialization method that's been registered
                with :mod:`kombu.serialization.registry`.
                Defaults to the :attr:`serializer` attribute.

            compression (str): Optional 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:`task_compression` setting.

            link (Signature): A single, or a list of tasks signatures
                to apply if the task returns successfully.

            link_error (Signature): A single, or a list of task signatures
                to apply if an error occurs while executing the task.

            producer (kombu.Producer): custom producer to use when publishing
                the task.

            add_to_parent (bool): 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

            ignore_result (bool): If set to `False` (default) the result
                of a task will be stored in the backend. If set to `True`
                the result will not be stored. This can also be set
                using the :attr:`ignore_result` in the `app.task` decorator.

            publisher (kombu.Producer): Deprecated alias to ``producer``.

            headers (Dict): Message headers to be included in the message.
                The headers can be used as an overlay for custom labeling
                using the :ref:`canvas-stamping` feature.

        Returns:
            celery.result.AsyncResult: Promise of future evaluation.

        Raises:
            TypeError: If not enough arguments are passed, or too many
                arguments are passed.  Note that signature checks may
                be disabled by specifying ``@task(typing=False)``.
            ValueError: If soft_time_limit and time_limit both are set
                but soft_time_limit is greater than time_limit
            kombu.exceptions.OperationalError: If a connection to the
               transport cannot be made, or if the connection is lost.

        Note:
            Also supports all keyword arguments supported by
            :meth:`kombu.Producer.publish`.
        z8soft_time_limit must be less than or equal to time_limitr0rur$r&N)�accept)rRrZr[)rR�producerrZr[Z
result_clsrWZ	task_type)r)r(�
ValueErrorr�Z
__header__�AttributeErrorr5�shadow_name�_get_exec_options�dict�
setdefaultrur$r�r�Ztask_always_eagerZproducer_or_acquirerNr&r}r�dumps�loadsr�applyrZ	send_taskr��AsyncResult)rBrCrDrRr�rZr[rW�optionsZcheck_argumentsZpreoptsr3Zeager_producerr&�body�content_type�content_encoding�datar0r0r1r��s^o



�
�*��(���zTask.apply_asynccCsdS)a�Override for custom task name in worker logs/monitoring.

        Example:
            .. code-block:: python

                from celery.utils.imports import qualname

                def shadow_name(task, args, kwargs, options):
                    return qualname(args[0])

                @app.task(shadow_name=shadow_name, serializer='pickle')
                def apply_function_async(fun, *args, **kwargs):
                    return fun(*args, **kwargs)

        Arguments:
            args (Tuple): Task positional arguments.
            kwargs (Dict): Task keyword arguments.
            options (Dict): Task execution options.
        Nr0)rBrCrDr�r0r0r1r�`szTask.shadow_namecKs�|dur|jn|}|dur |jn|}|dur2|jn|}i|���|�}|jpNi}|�d�}|durj||d<|rx||d<n4|�d�}	|�d�}
|	dkr�|
r�|
|d<n
|�|�|j|||fd|i|��S)Nr$r!r#r"r+r�)�requestrCrDrjrrrNr>r)rBr�rCrDr!Z
extra_optionsr�rrr$r#r"r0r0r1�signature_from_requestus,






���zTask.signature_from_requestc
Ks4|j}	|	jd}
|dur||_|dur,|jn|}|	jrHt|pDtdd��|sZ|durZ|j}|	j}|j	|	||f|||
d�|��}|dur�|
|kr�|r�t|�|j
d�|j|	j
|j|j�|j|jd��t||p�|||d�}
|r�|r�|
�|
Sz|��Wn2t�y$}zt|dd	��WYd}~n
d}~00|�r0|
�|
S)
aRetry the task, adding it to the back of the queue.

        Example:
            >>> 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)

        Note:
            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 won't be executed.

        Arguments:
            args (Tuple): Positional arguments to retry with.
            kwargs (Dict): Keyword arguments to retry with.
            exc (Exception): Custom exception to report when the max retry
                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 re-raise the current exception.

                If no exception was raised it will raise the ``exc``
                argument provided.
            countdown (float): Time in seconds to delay the retry for.
            eta (~datetime.datetime): Explicit time and date to run the
                retry at.
            max_retries (int): If set, overrides the default retry limit for
                this execution.  Changes to this parameter don't propagate to
                subsequent task retry attempts.  A value of :const:`None`,
                means "use the default", so if you want infinite retries you'd
                have to set the :attr:`max_retries` attribute of the task to
                :const:`None` first.
            time_limit (int): If set, overrides the default time limit.
            soft_time_limit (int): If set, overrides the default soft
                time limit.
            throw (bool): If this is :const:`False`, don't 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 after the retry call.
            **options (Any): Extra options to pass on to :meth:`apply_async`.

        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.
        rNzTask can be retried)�	countdownrsr\z$Can't retry {}[{}] args:{} kwargs:{})Z	task_argsZtask_kwargs)�exc�whenrv�sigF)Zrequeue)r�r\Zoverride_max_retries�max_retriesrqrr�default_retry_delayrvr�rr,r�rcrCrDr��	Exceptionr)rBrCrDr��throwrsr�r�r�r�r\rv�S�retr0r0r1�retry�sL>
�����"z
Task.retrycs�ddlm}|��}
|pd}|p"i}|p,t�}|p4d}|durF|
jj}|
j|j}||j|d||	pddt�t	|�t	|�|
��
dd�d��
d���
d	���
d
�d�d�}d
�vr�t	�d
�|d
<�fdd�|d
D�|d<d}||j|d||��d�}|||||�}|j}t|t
��r2|j|j}}t|t��r2|j}t|t��r\|jdu�r\|jj|dd�S|jdu�rntjn|jj}t|||||jd�S)a�Execute this task locally, by blocking until the task returns.

        Arguments:
            args (Tuple): positional arguments passed on to the task.
            kwargs (Dict): keyword arguments passed on to the task.
            throw (bool): Re-raise task exceptions.
                Defaults to the :setting:`task_eager_propagates` setting.

        Returns:
            celery.result.EagerResult: pre-evaluated result.
        r)�build_tracerr0NTruFr#r"r$)rvr#r"r$)rcr:r\rvrwrxrtrdrer?rurrracsi|]}|t��|g���qSr0)rrN)�.0�header�r�r0r1�
<dictcomp>1szTask.apply.<locals>.<dictcomp>r`)�eager�	propagater3r)r\)�	tracebackr�)Zcelery.app.tracer�r�rr�Ztask_eager_propagatesZ_tasksr�rrrN�retval�
isinstancer�	exceptionr�rr�rr�r��infor�SUCCESS�stater)rBrCrDrZr[rRr\r�rwrxr?r�r�r3r:r��tbZtracerr�r�r�r0r�r1r��s\

��
�
�z
Task.applycKs |��j|f|j|jd�|��S)z�Get AsyncResult instance for the specified task.

        Arguments:
            task_id (str): Task id to get result for.
        )�backendZ	task_name)r�r�r�r�)rBrRrDr0r0r1r�Es
��zTask.AsyncResultcOs&|�d|j�t||g|�Ri|��S)z�Create signature.

        Returns:
            :class:`~celery.signature`:  object for
                this task, wrapping arguments and execution options
                for a single task invocation.
        r3)r�r3r)rBrCZstarargsZ
starkwargsr0r0r1rNszTask.signaturecOs|�||�S)zUCreate signature.

        Shortcut for ``.s(*a, **k) -> .signature(a, k)``.
        �rrAr0r0r1�sZszTask.scOs|j||dd�S)zpCreate immutable signature.

        Shortcut for ``.si(*a, **k) -> .signature(a, k, immutable=True)``.
        T)Z	immutabler�rAr0r0r1�siaszTask.sicCs"ddlm}||��|||jd�S)z;Create a :class:`~celery.canvas.chunks` task for this task.r)�chunks�r3)�celeryr�r�r3)rB�it�nr�r0r0r1r�hszTask.chunkscCs ddlm}||��||jd�S)z7Create a :class:`~celery.canvas.xmap` task from ``it``.r)�xmapr�)r�r�r�r3)rBr�r�r0r0r1�mapmszTask.mapcCs ddlm}||��||jd�S)z;Create a :class:`~celery.canvas.xstarmap` task from ``it``.r)�xstarmapr�)r�r�r�r3)rBr�r�r0r0r1�starmaprszTask.starmapcKsj|j}|dur|jjj}|jjj|jd��,}|j|f|j||d�|��Wd�S1s\0YdS)a�Send monitoring event message.

        This can be used to add custom event types in :pypi:`Flower`
        and other monitors.

        Arguments:
            type_ (str):  Type of event, e.g. ``"task-failed"``.

        Keyword Arguments:
            retry (bool):  Retry sending the message
                if the connection is lost.  Default is taken from the
                :setting:`task_publish_retry` setting.
            retry_policy (Mapping): Retry settings.  Default is taken
                from the :setting:`task_publish_retry_policy` setting.
            **fields (Any): Map containing information about the event.
                Must be JSON serializable.
        N)rt)rr��retry_policy)	r�r3r�Ztask_publish_retry_policy�eventsZdefault_dispatcherrt�sendrc)rB�type_r�r��fields�reqr�r0r0r1�
send_eventws
���zTask.send_eventc	Cs�|jj}d|jvrtd��t|t�r8t|dd�s8td��t|t�rZ||jj	dj
dd�O}t|jj�phgD]}|�
|�qjt|jj�p�gD]}|�|�q�t|t�r�d	|jvr�|j	d
j�d	g�}|�t|jd	��|�|jj�|j�dd�d}|j||jj|jj|jj|d
�t|t��rFt|j	��p0gD]}|j|d��q2t|jj�pTg�D](}t||jd�}|j|d�||O}�qX|�|�S)aKReplace this task, with a new task inheriting the task id.

        Execution of the host task ends immediately and no subsequent statements
        will be run.

        .. versionadded:: 4.0

        Arguments:
            sig (Signature): signature to replace with.
            visitor (StampingVisitor): Visitor API object.

        Raises:
            ~@Ignore: This is always raised when called in asynchronous context.
            It is best to always use ``return self.replace(...)`` to convey
            to the reader that the task won't continue after being replaced.
        rXz8A signature replacing a task must not be part of a chord�tasksTz"Cannot replace with an empty chainzcelery.accumulater)�indexrZ���r^r)rXrUrVrSr^)r^r�)r�rXr�rr�r
rMrr3r�r�rrdrZrer[r��extend�freezercrN�setrVrS�reversedrYr�
on_replace)	rBr�rX�callbackZerrbackZfinal_task_linksr^Z
chain_task�tr0r0r1�replace�sB
�
�
zTask.replacecCs\|jjstd��|j|jj|jj|jj|jjd�|��}|j�	|jj|�|sX|�
�S|S)a{Add signature to the chord the current task is a member of.

        .. versionadded:: 4.0

        Currently only supported by the Redis result backend.

        Arguments:
            sig (Signature): Signature to extend chord with.
            lazy (bool): If enabled the new task won't actually be called,
                and ``sig.delay()`` must be called manually.
        z'Current task is not member of any chord)rUrVrXrS)r�rXr�r�rrVrSr�r��add_to_chordr�)rBr�Zlazy�resultr0r0r1r��s�zTask.add_to_chordcKs2|dur|jj}|jj|||fd|ji|��dS)z�Update task state.

        Arguments:
            task_id (str): Id of the task to update.
                Defaults to the id of the current task.
            state (str): New state.
            meta (Dict): State meta-data.
        Nr�)r�rcr�Zstore_result)rBrRr��metarDr0r0r1�update_state�s	���zTask.update_statecCsdS)a�Handler called before the task starts.

        .. versionadded:: 5.2

        Arguments:
            task_id (str): Unique id of the task to execute.
            args (Tuple): Original arguments for the task to execute.
            kwargs (Dict): Original keyword arguments for the task to execute.

        Returns:
            None: The return value of this handler is ignored.
        Nr0)rBrRrCrDr0r0r1�before_start�szTask.before_startcCsdS)a�Success handler.

        Run by the worker if the task executes successfully.

        Arguments:
            retval (Any): The return value of the task.
            task_id (str): Unique id of the executed task.
            args (Tuple): Original arguments for the executed task.
            kwargs (Dict): Original keyword arguments for the executed task.

        Returns:
            None: The return value of this handler is ignored.
        Nr0)rBr�rRrCrDr0r0r1�
on_success	szTask.on_successcCsdS)aRetry handler.

        This is run by the worker when the task is to be retried.

        Arguments:
            exc (Exception): The exception sent to :meth:`retry`.
            task_id (str): Unique id of the retried task.
            args (Tuple): Original arguments for the retried task.
            kwargs (Dict): Original keyword arguments for the retried task.
            einfo (~billiard.einfo.ExceptionInfo): Exception information.

        Returns:
            None: The return value of this handler is ignored.
        Nr0�rBr�rRrCrD�einfor0r0r1�on_retrysz
Task.on_retrycCsdS)a
Error handler.

        This is run by the worker when the task fails.

        Arguments:
            exc (Exception): The exception raised by the task.
            task_id (str): Unique id of the failed task.
            args (Tuple): Original arguments for the task that failed.
            kwargs (Dict): Original keyword arguments for the task that failed.
            einfo (~billiard.einfo.ExceptionInfo): Exception information.

        Returns:
            None: The return value of this handler is ignored.
        Nr0r�r0r0r1�
on_failure(szTask.on_failurecCsdS)a�Handler called after the task returns.

        Arguments:
            status (str): Current task state.
            retval (Any): Task return value/exception.
            task_id (str): Unique id of the task.
            args (Tuple): Original arguments for the task.
            kwargs (Dict): Original keyword arguments for the task.
            einfo (~billiard.einfo.ExceptionInfo): Exception information.

        Returns:
            None: The return value of this handler is ignored.
        Nr0)rB�statusr�rRrCrDrr0r0r1�after_return8szTask.after_returncCs(|jjr|����S|��td��dS)aHandler called when the task is replaced.

        Must return super().on_replace(sig) when overriding to ensure the task replacement
        is properly handled.

        .. versionadded:: 5.3

        Arguments:
            sig (Signature): signature to replace with.
        zReplaced by new taskN)r�rvr�rNr�r
)rBr�r0r0r1r�GszTask.on_replacecCs|jr|jj�|�|Sr=)�trailr�rlr6)rBr�r0r0r1�	add_trailYszTask.add_trailcOs&|j�t|ii|jj�|����dSr=)r�r�rr�rGrAr0r0r1r�^szTask.push_requestcCs|j��dSr=)r�rIrLr0r0r1r�aszTask.pop_requestcCs
t|t�S)z``repr(task)``.)r<�
R_INSTANCErLr0r0r1rQdsz
Task.__repr__cCs,|jj}|dur(|jdur"t�|_|jS|S)zGet current request object.N)r��top�_default_requestr)rBr�r0r0r1�_get_requesths
zTask._get_requestcCs|jdurt|�|_|jSr=)r��extract_exec_optionsrLr0r0r1r�ts

zTask._get_exec_optionscCs|j}|dur|jjS|Sr=)�_backendr3r�)rBr�r0r0r1r�yszTask.backendcCs
||_dSr=)r)rBr�r0r0r1r��scCs|jjSr=)�	__class__rmrLr0r0r1rm�sz
Task.__name__)NNNNNNN)NNNN)NNNTNNN)
NNNNNNNNNN)N)TN)F)NNN)UrmrnrorpZ	__trace__r5rrr��Requestr7r�r�r�r�r~rurZsend_eventsr�r&r(r)r�rr�r�r�Zthrowsr%r$Zresultrepr_maxsizer�r	rr�r�r�r�classmethodr�r�r�rr3r�r�r�r�r�r�r�r�r�r�Zsubtask_from_requestr�r�r�rZsubtaskr�r�r�r�r�r�r�r�r�r�r�rrrr�rr�r�rQr
rzr�r��setterr0r0r0r1r �s�







	

�
#�
�
q�
F	


D




r )r+)NN)?rpr�Zbilliard.einforrZkomburZkombu.exceptionsrZkombu.utils.uuidrr�rrZ
celery._stater	Z
celery.canvasr
rrZcelery.exceptionsr
rrrrZcelery.localrZ
celery.resultrrZcelery.utilsrZcelery.utils.functionalrrZcelery.utils.importsrZcelery.utils.nodenamesrZcelery.utils.serializationrr�rr��registryr�utilsr�__all__rr8r9rr�ZTaskTyper2r<rZCallableTask�registerr ZBaseTaskr0r0r0r1�<module>sT
�

gl