
     hF#                        d Z ddlZddlmZmZmZmZ ddlmZ ddl	m
Z
 dZdZdGdZ G d	 d
e          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          ZeZ G d de          Z G d de          Z G d d e          Z G d! d"e          Z G d# d$e          Z G d% d&ee          Z  G d' d(e          Z! G d) d*ee          Z" G d+ d,e          Z# G d- d.e          Z$ G d/ d0e          Z% G d1 d2e          Z& G d3 d4e          Z' G d5 d6e          Z( G d7 d8e)          Z* G d9 d:e+          Z, G d; d<e-          Z.e.Z/ G d= d>e-          Z0 G d? d@e          Z1 G dA dBe1          Z2 G dC dDe1          Z3 G dE dFe          Z4dS )Ha  Celery error types.

Error Hierarchy
===============

- :exc:`Exception`
    - :exc:`celery.exceptions.CeleryError`
        - :exc:`~celery.exceptions.ImproperlyConfigured`
        - :exc:`~celery.exceptions.SecurityError`
        - :exc:`~celery.exceptions.TaskPredicate`
            - :exc:`~celery.exceptions.Ignore`
            - :exc:`~celery.exceptions.Reject`
            - :exc:`~celery.exceptions.Retry`
        - :exc:`~celery.exceptions.TaskError`
            - :exc:`~celery.exceptions.QueueNotFound`
            - :exc:`~celery.exceptions.IncompleteStream`
            - :exc:`~celery.exceptions.NotRegistered`
            - :exc:`~celery.exceptions.AlreadyRegistered`
            - :exc:`~celery.exceptions.TimeoutError`
            - :exc:`~celery.exceptions.MaxRetriesExceededError`
            - :exc:`~celery.exceptions.TaskRevokedError`
            - :exc:`~celery.exceptions.InvalidTaskError`
            - :exc:`~celery.exceptions.ChordError`
        - :exc:`~celery.exceptions.BackendError`
            - :exc:`~celery.exceptions.BackendGetMetaError`
            - :exc:`~celery.exceptions.BackendStoreError`
    - :class:`kombu.exceptions.KombuError`
        - :exc:`~celery.exceptions.OperationalError`

            Raised when a transport connection error occurs while
            sending a message (be it a task, remote control command error).

            .. note::
                This exception does not inherit from
                :exc:`~celery.exceptions.CeleryError`.
    - **billiard errors** (prefork pool)
        - :exc:`~celery.exceptions.SoftTimeLimitExceeded`
        - :exc:`~celery.exceptions.TimeLimitExceeded`
        - :exc:`~celery.exceptions.WorkerLostError`
        - :exc:`~celery.exceptions.Terminated`
- :class:`UserWarning`
    - :class:`~celery.exceptions.CeleryWarning`
        - :class:`~celery.exceptions.AlwaysEagerIgnored`
        - :class:`~celery.exceptions.DuplicateNodenameWarning`
        - :class:`~celery.exceptions.FixupWarning`
        - :class:`~celery.exceptions.NotConfigured`
        - :class:`~celery.exceptions.SecurityWarning`
- :exc:`BaseException`
    - :exc:`SystemExit`
        - :exc:`~celery.exceptions.WorkerTerminate`
        - :exc:`~celery.exceptions.WorkerShutdown`
    N)SoftTimeLimitExceeded
TerminatedTimeLimitExceededWorkerLostError)ClickException)OperationalError)%reraiseCeleryWarningAlwaysEagerIgnoredDuplicateNodenameWarningFixupWarningNotConfiguredSecurityWarningCeleryErrorImproperlyConfiguredSecurityErrorr   TaskPredicateIgnoreRejectRetry	TaskErrorQueueNotFoundIncompleteStreamNotRegisteredAlreadyRegisteredTimeoutErrorMaxRetriesExceededErrorTaskRevokedErrorInvalidTaskError
ChordErrorBackendErrorBackendGetMetaErrorBackendStoreErrorr   r   r   r   CPendingDeprecationWarningCDeprecationWarningWorkerShutdownWorkerTerminateCeleryCommandExceptionzBTask of kind {0} never registered, please make sure it's imported.c                 B    |j         |ur|                    |          |)zReraise exception.)__traceback__with_traceback)tpvaluetbs      M/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/celery/exceptions.pyr	   r	   i   s)    "$$""2&&&
K    c                       e Zd ZdZdS )r
   z#Base class for all Celery warnings.N__name__
__module____qualname____doc__ r0   r/   r
   r
   p   s        ----r0   r
   c                       e Zd ZdZdS )r   z6send_task ignores :setting:`task_always_eager` option.Nr2   r7   r0   r/   r   r   t   s        @@@@r0   r   c                       e Zd ZdZdS )r   z-Multiple workers are using the same nodename.Nr2   r7   r0   r/   r   r   x           7777r0   r   c                       e Zd ZdZdS )r   zFixup related warning.Nr2   r7   r0   r/   r   r   |   s            r0   r   c                       e Zd ZdZdS )r   zBCelery hasn't been configured, as no config module has been found.Nr2   r7   r0   r/   r   r      s        LLLLr0   r   c                       e Zd ZdZdS )r   zPotential security issue found.Nr2   r7   r0   r/   r   r              ))))r0   r   c                       e Zd ZdZdS )r   z!Base class for all Celery errors.Nr2   r7   r0   r/   r   r      s        ++++r0   r   c                       e Zd ZdZdS )r   z,Base class for task-related semi-predicates.Nr2   r7   r0   r/   r   r      s        6666r0   r   c                   F     e Zd ZdZdZdZdZ	 	 d fd	Zd Zd Z	d Z
 xZS )	r   z The task is to be retried later.NFc                    ddl m} || _        t          |t                    rd |c| _        | _        n||r ||          nd c| _        | _        || _        || _        || _	         t                      j        | ||fi | d S )Nr   )	safe_repr)kombu.utils.encodingrC   message
isinstancestrexcexcswhenis_eagersigsuper__init__)	selfrE   rH   rJ   rK   rL   kwargsrC   	__class__s	           r/   rN   zRetry.__init__   s    222222c3 	G"&DHdii"%'Fyy~~~$DHdi	 sD33F33333r0   c                 j    t          | j        t          j                  rd| j         dS d| j         S )Nzin szat )rF   rJ   numbersNumberrO   s    r/   humanizezRetry.humanize   s;    di00 	&%%%%% TY   r0   c                     | j         r| j         S | j        rd|                                  d| j         S d|                                  S )NzRetry : )rE   rI   rW   rV   s    r/   __str__zRetry.__str__   sT    < 	 <9 	;:DMMOO::ty:::))))r0   c                 8    | j         | j        | j        | j        ffS N)rQ   rE   rH   rJ   rV   s    r/   
__reduce__zRetry.__reduce__   s    ~dh	BBBr0   )NNNFN)r3   r4   r5   r6   rE   rH   rJ   rN   rW   rZ   r]   __classcell__rQ   s   @r/   r   r      s        ** G C DCH4 4 4 4 4 4! ! !
* * *C C C C C C Cr0   r   c                       e Zd ZdZdS )r   z4A task can raise this to ignore doing state updates.Nr2   r7   r0   r/   r   r      s        >>>>r0   r   c                   *     e Zd ZdZd fd	Zd Z xZS )r   zAA task can raise this if it wants to reject/re-queue the message.NFc                 h    || _         || _        t                                          ||           d S r\   )reasonrequeuerM   rN   )rO   rc   rd   rQ   s      r/   rN   zReject.__init__   s1    )))))r0   c                 &    d| j          d| j         S )Nzreject requeue=rY   )rd   rc   rV   s    r/   __repr__zReject.__repr__   s    >>>>>>r0   )NFr3   r4   r5   r6   rN   rf   r^   r_   s   @r/   r   r      sR        KK* * * * * *
? ? ? ? ? ? ?r0   r   c                       e Zd ZdZdS )r   z(Celery is somehow improperly configured.Nr2   r7   r0   r/   r   r      s        2222r0   r   c                       e Zd ZdZdS )r   zSecurity related exception.Nr2   r7   r0   r/   r   r      s        %%%%r0   r   c                       e Zd ZdZdS )r   zTask related errors.Nr2   r7   r0   r/   r   r      s        r0   r   c                       e Zd ZdZdS )r   z.Task routed to a queue not in ``conf.queues``.Nr2   r7   r0   r/   r   r      s        8888r0   r   c                       e Zd ZdZdS )r   z?Found the end of a stream of data, but the data isn't complete.Nr2   r7   r0   r/   r   r      s        IIIIr0   r   c                       e Zd ZdZd ZdS )r   zThe task is not registered.c                 6    t                               |           S r\   )UNREGISTERED_FMTformatrV   s    r/   rf   zNotRegistered.__repr__   s    &&t,,,r0   N)r3   r4   r5   r6   rf   r7   r0   r/   r   r      s)        %%- - - - -r0   r   c                       e Zd ZdZdS )r   zThe task is already registered.Nr2   r7   r0   r/   r   r      r>   r0   r   c                       e Zd ZdZdS )r   zThe operation timed out.Nr2   r7   r0   r/   r   r      s        """"r0   r   c                   "     e Zd ZdZ fdZ xZS )r   z.The tasks max restart limit has been exceeded.c                     |                     dg           | _        |                     dt                                | _         t	                      j        |i | d S )N	task_argstask_kwargs)popru   dictrv   rM   rN   )rO   argsrP   rQ   s      r/   rN   z MaxRetriesExceededError.__init__   sT    K44!::mTVV<<$)&)))))r0   r3   r4   r5   r6   rN   r^   r_   s   @r/   r   r      s>        88* * * * * * * * *r0   r   c                       e Zd ZdZdS )r   z2The task has been revoked, so no result available.Nr2   r7   r0   r/   r   r      s        <<<<r0   r   c                       e Zd ZdZdS )r   z8The task has invalid data or ain't properly constructed.Nr2   r7   r0   r/   r   r      s        BBBBr0   r   c                       e Zd ZdZdS )r    z-A task part of the chord raised an exception.Nr2   r7   r0   r/   r    r      r:   r0   r    c                       e Zd ZdZdS )r$   zWarning of pending deprecation.Nr2   r7   r0   r/   r$   r$     r>   r0   r$   c                       e Zd ZdZdS )r%   zWarning of deprecation.Nr2   r7   r0   r/   r%   r%   
  s        !!!!r0   r%   c                       e Zd ZdZdS )r'   z5Signals that the worker should terminate immediately.Nr2   r7   r0   r/   r'   r'     s        ????r0   r'   c                       e Zd ZdZdS )r&   z7Signals that the worker should perform a warm shutdown.Nr2   r7   r0   r/   r&   r&     s        AAAAr0   r&   c                       e Zd ZdZdS )r!   z0An issue writing or reading to/from the backend.Nr2   r7   r0   r/   r!   r!     s        ::::r0   r!   c                   (     e Zd ZdZd Z fdZ xZS )r"   z"An issue reading from the backend.c                 <    |                     dd          | _        d S )Ntask_id )getr   rO   ry   rP   s      r/   rN   zBackendGetMetaError.__init__   s    zz)R00r0   c                 Z    t                                                      dz   | j        z   S )N	 task_id:)rM   rf   r   rO   rQ   s    r/   rf   zBackendGetMetaError.__repr__#  s%    ww!!K/$,>>r0   rg   r_   s   @r/   r"   r"     sM        ,,1 1 1? ? ? ? ? ? ? ? ?r0   r"   c                   (     e Zd ZdZd Z fdZ xZS )r#   z An issue writing to the backend.c                 r    |                     dd          | _        |                     dd          | _        d S )Nstater   r   )r   r   r   r   s      r/   rN   zBackendStoreError.__init__*  s0    ZZ,,
zz)R00r0   c                 p    t                                                      dz   | j        z   dz   | j        z   S )Nz state:r   )rM   rf   r   r   r   s    r/   rf   zBackendStoreError.__repr__.  s1    ww!!I-
:[H4<WWr0   rg   r_   s   @r/   r#   r#   '  sV        **1 1 1X X X X X X X X Xr0   r#   c                   "     e Zd ZdZ fdZ xZS )r(   z6A general command exception which stores an exit code.c                 Z    t                                          |           || _        d S )N)rE   )rM   rN   	exit_code)rO   rE   r   rQ   s      r/   rN   zCeleryCommandException.__init__5  s)    )))"r0   rz   r_   s   @r/   r(   r(   2  s>        @@# # # # # # # # #r0   r(   r\   )5r6   rT   billiard.exceptionsr   r   r   r   clickr   kombu.exceptionsr   __all__ro   r	   UserWarningr
   r   r   r   r   r   	Exceptionr   r   r   RetryTaskErrorr   r   r   r   r   KeyErrorr   r   r   r   r   r   r   r   r    PendingDeprecationWarningr$   DeprecationWarningr%   
SystemExitr'   SystemTerminater&   r!   r"   r#   r(   r7   r0   r/   <module>r      s   3 3j E E E E E E E E E E E E             - - - - - -%N 
   . . . . .K . . .A A A A A A A A8 8 8 8 8} 8 8 8! ! ! ! != ! ! !M M M M MM M M M* * * * *m * * *, , , , ,) , , ,7 7 7 7 7K 7 7 7'C 'C 'C 'C 'CM 'C 'C 'CT ? ? ? ? ?] ? ? ?	? 	? 	? 	? 	?] 	? 	? 	?3 3 3 3 3; 3 3 3& & & & &K & & &       9 9 9 9 9Hi 9 9 9J J J J Jy J J J- - - - -Hi - - -* * * * *	 * * *
# # # # #9 # # #* * * * *i * * *= = = = =y = = =C C C C Cy C C C8 8 8 8 8 8 8 8* * * * *!: * * *" " " " ", " " "@ @ @ @ @j @ @ @ "B B B B BZ B B B; ; ; ; ;9 ; ; ;? ? ? ? ?, ? ? ?X X X X X X X X# # # # #^ # # # # #r0   