Ë
    –V.j~#  ã                   ó  — 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dlmZ dZdHd	„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 d0„ d1e «      Z' G d2„ d3e «      Z( G d4„ d5e «      Z) G d6„ d7e «      Z* G d8„ d9e+«      Z, G d:„ d;e-«      Z. G d<„ d=e/«      Z0e0Z1 G d>„ d?e/«      Z2 G d@„ dAe«      Z3 G dB„ dCe3«      Z4 G dD„ dEe3«      Z5 G dF„ dGe«      Z6y)IaË  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ÚCeleryCommandException)Úget_pickleable_exceptionzBTask of kind {0} never registered, please make sure it's imported.c                 óD   — |j                   |ur|j                  |«      ‚|‚)zReraise exception.)Ú__traceback__Úwith_traceback)ÚtpÚvalueÚtbs      úSC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\celery/exceptions.pyr	   r	   j   s&   € à×Ñ "Ñ$Ø×"Ñ" 2Ó&Ð&Ø
€Kó    c                   ó   — e Zd ZdZy)r
   z#Base class for all Celery warnings.N©Ú__name__Ú
__module__Ú__qualname__Ú__doc__© r1   r0   r
   r
   q   s   „ Ú-r1   r
   c                   ó   — e Zd ZdZy)r   z6send_task ignores :setting:`task_always_eager` option.Nr3   r8   r1   r0   r   r   u   s   „ Ú@r1   r   c                   ó   — e Zd ZdZy)r   z-Multiple workers are using the same nodename.Nr3   r8   r1   r0   r   r   y   ó   „ Ú7r1   r   c                   ó   — e Zd ZdZy)r   zFixup related warning.Nr3   r8   r1   r0   r   r   }   s   „ Ú r1   r   c                   ó   — e Zd ZdZy)r   zBCelery hasn't been configured, as no config module has been found.Nr3   r8   r1   r0   r   r   �   s   „ ÚLr1   r   c                   ó   — e Zd ZdZy)r   zPotential security issue found.Nr3   r8   r1   r0   r   r   …   ó   „ Ú)r1   r   c                   ó   — e Zd ZdZy)r   z!Base class for all Celery errors.Nr3   r8   r1   r0   r   r   ‰   s   „ Ú+r1   r   c                   ó   — e Zd ZdZy)r   z,Base class for task-related semi-predicates.Nr3   r8   r1   r0   r   r   �   s   „ Ú6r1   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.Nc                 óò   •— ddl m} || _        t        |t        «      rd |c| _        | _        n"t        |«      |r ||«      nd c| _        | _        || _        || _	        || _
        t        ‰| �0  | ||fi |¤Ž y )Nr   )Ú	safe_repr)Úkombu.utils.encodingrD   ÚmessageÚ
isinstanceÚstrÚexcÚexcsr)   ÚwhenÚis_eagerÚsigÚsuperÚ__init__)	ÚselfrF   rI   rK   rL   rM   ÚkwargsrD   Ú	__class__s	           €r0   rO   zRetry.__init__ž   sq   ø€ å2ØˆŒÜ�cœ3ÔØ"&¨ÐˆDŒH�d•iä":¸3Ó"?ÑSVÁÈ3ÄÐ\`ÐˆDŒH�d”iØˆŒ	Ø ˆŒØˆŒÜ‰Ñ˜˜s DÑ3¨FÓ3r1   c                 óˆ   — t        | j                  t        j                  «      rd| j                  › d�S d| j                  › �S )Nzin Úszat )rG   rK   ÚnumbersÚNumber©rP   s    r0   ÚhumanizezRetry.humanize«   s8   € Ü�d—i‘i¤§¡Ô0Ø˜Ÿ™˜ 1Ð%Ð%Ø�T—Y‘Y�KÐ Ð r1   c                 ó°   — | j                   r| j                   S | j                  r d| j                  «       › d| j                  › �S d| j                  «       › �S )NzRetry ú: )rF   rJ   rX   rW   s    r0   Ú__str__zRetry.__str__°   sL   € Ø�<Š<Ø—<‘<ÐØ�9Š9Ø˜DŸM™M›OÐ,¨B¨t¯y©y¨kÐ:Ð:Ø˜Ÿ™›Ð(Ð)Ð)r1   c                 ó`   — | j                   | j                  | j                  | j                  ffS ©N)rR   rF   rI   rK   rW   s    r0   Ú
__reduce__zRetry.__reduce__·   s$   € Ø�~‰~ §¡¨d¯h©h¸¿	¹	ÐBÐBÐBr1   )NNNFN)r4   r5   r6   r7   rF   rI   rK   rO   rX   r[   r^   Ú__classcell__©rR   s   @r0   r   r   ‘   s6   ø„ Ù*ð €Gð €Cð €DàCHØõ4ò!ò
*öCr1   r   c                   ó   — e Zd ZdZy)r   z4A task can raise this to ignore doing state updates.Nr3   r8   r1   r0   r   r   ¾   s   „ Ú>r1   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.c                 óB   •— || _         || _        t        ‰| �  ||«       y r]   )ÚreasonÚrequeuerN   rO   )rP   rd   re   rR   s      €r0   rO   zReject.__init__Å   s    ø€ ØˆŒØˆŒÜ‰Ñ˜ Õ)r1   c                 ó:   — d| j                   › d| j                  › �S )Nzreject requeue=rZ   )re   rd   rW   s    r0   Ú__repr__zReject.__repr__Ê   s   € Ø  §¡ ¨b°·±°Ð>Ð>r1   )NF©r4   r5   r6   r7   rO   rg   r_   r`   s   @r0   r   r   Â   s   ø„ ÙKõ*ö
?r1   r   c                   ó   — e Zd ZdZy)r   z(Celery is somehow improperly configured.Nr3   r8   r1   r0   r   r   Î   s   „ Ú2r1   r   c                   ó   — e Zd ZdZy)r   zSecurity related exception.Nr3   r8   r1   r0   r   r   Ò   s   „ Ú%r1   r   c                   ó   — e Zd ZdZy)r   zTask related errors.Nr3   r8   r1   r0   r   r   Ö   s   „ Úr1   r   c                   ó   — e Zd ZdZy)r   z.Task routed to a queue not in ``conf.queues``.Nr3   r8   r1   r0   r   r   Ú   s   „ Ú8r1   r   c                   ó   — e Zd ZdZy)r   z?Found the end of a stream of data, but the data isn't complete.Nr3   r8   r1   r0   r   r   Þ   s   „ ÚIr1   r   c                   ó   — e Zd ZdZd„ Zy)r   zThe task is not registered.c                 ó,   — t         j                  | «      S r]   )ÚUNREGISTERED_FMTÚformatrW   s    r0   rg   zNotRegistered.__repr__å   s   € Ü×&Ñ& tÓ,Ð,r1   N)r4   r5   r6   r7   rg   r8   r1   r0   r   r   â   s
   „ Ù%ó-r1   r   c                   ó   — e Zd ZdZy)r   zThe task is already registered.Nr3   r8   r1   r0   r   r   é   r?   r1   r   c                   ó   — e Zd ZdZy)r   zThe operation timed out.Nr3   r8   r1   r0   r   r   î   s   „ Ú"r1   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                 ó�   •— |j                  dg «      | _        |j                  dt        «       «      | _        t	        ‰| �  |i |¤Ž y )NÚ	task_argsÚtask_kwargs)Úpoprv   Údictrw   rN   rO   )rP   ÚargsrQ   rR   s      €r0   rO   z MaxRetriesExceededError.__init__õ   s<   ø€ ØŸ™ K°Ó4ˆŒØ!Ÿ:™: m´T³VÓ<ˆÔÜ‰Ñ˜$Ð) &Ó)r1   ©r4   r5   r6   r7   rO   r_   r`   s   @r0   r   r   ò   s   ø„ Ù8÷*ð *r1   r   c                   ó   — e Zd ZdZy)r   z2The task has been revoked, so no result available.Nr3   r8   r1   r0   r   r   û   s   „ Ú<r1   r   c                   ó   — e Zd ZdZy)r   z8The task has invalid data or ain't properly constructed.Nr3   r8   r1   r0   r   r   ÿ   s   „ ÚBr1   r   c                   ó   — e Zd ZdZy)r    z-A task part of the chord raised an exception.Nr3   r8   r1   r0   r    r      r;   r1   r    c                   ó   — e Zd ZdZy)r$   zWarning of pending deprecation.Nr3   r8   r1   r0   r$   r$     r?   r1   r$   c                   ó   — e Zd ZdZy)r%   zWarning of deprecation.Nr3   r8   r1   r0   r%   r%     s   „ Ú!r1   r%   c                   ó   — e Zd ZdZy)r'   z5Signals that the worker should terminate immediately.Nr3   r8   r1   r0   r'   r'     s   „ Ú?r1   r'   c                   ó   — e Zd ZdZy)r&   z7Signals that the worker should perform a warm shutdown.Nr3   r8   r1   r0   r&   r&     s   „ ÚAr1   r&   c                   ó   — e Zd ZdZy)r!   z0An issue writing or reading to/from the backend.Nr3   r8   r1   r0   r!   r!     s   „ Ú:r1   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                 ó2   — |j                  dd«      | _        y )NÚtask_idÚ )Úgetr†   ©rP   rz   rQ   s      r0   rO   zBackendGetMetaError.__init__!  s   € Ø—z‘z )¨RÓ0ˆ�r1   c                 ó@   •— t         ‰| �  «       dz   | j                  z   S )Nú	 task_id:)rN   rg   r†   ©rP   rR   s    €r0   rg   zBackendGetMetaError.__repr__$  s   ø€ Ü‰wÑÓ! KÑ/°$·,±,Ñ>Ð>r1   rh   r`   s   @r0   r"   r"     s   ø„ Ù,ò1÷?ð ?r1   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                 ó`   — |j                  dd«      | _        |j                  dd«      | _        y )NÚstater‡   r†   )rˆ   r�   r†   r‰   s      r0   rO   zBackendStoreError.__init__+  s&   € Ø—Z‘Z ¨Ó,ˆŒ
Ø—z‘z )¨RÓ0ˆ�r1   c                 ó`   •— t         ‰| �  «       dz   | j                  z   dz   | j                  z   S )Nz state:r‹   )rN   rg   r�   r†   rŒ   s    €r0   rg   zBackendStoreError.__repr__/  s-   ø€ Ü‰wÑÓ! IÑ-°·
±
Ñ:¸[ÑHÈ4Ï<É<ÑWÐWr1   rh   r`   s   @r0   r#   r#   (  s   ø„ Ù*ò1÷Xð Xr1   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                 ó4   •— t         ‰| �  |¬«       || _        y )N)rF   )rN   rO   Ú	exit_code)rP   rF   r“   rR   s      €r0   rO   zCeleryCommandException.__init__6  s   ø€ Ü‰Ñ ÐÔ)Ø"ˆ�r1   r{   r`   s   @r0   r(   r(   3  s   ø„ Ù@÷#ð #r1   r(   r]   )7r7   rU   Úbilliard.exceptionsr   r   r   r   Úclickr   Úkombu.exceptionsr   Ú__all__Úcelery.utils.serializationr)   rp   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(   r8   r1   r0   Ú<module>r¡      sÐ  ðñ3ój ç eÓ eÝ  Ý -ð%€õN @ðÐ ó
ô.�Kô .ôA˜ô Aô8˜}ô 8ô!�=ô !ôM�Mô Mô*�mô *ô,�)ô ,ô7�Kô 7ô'CˆMô 'CðT €ô?ˆ]ô ?ô	?ˆ]ô 	?ô3˜;ô 3ô&�Kô &ô�ô ô9�H˜iô 9ôJ�yô Jô-�H˜iô -ô*˜	ô *ô
#�9ô #ô*˜iô *ô=�yô =ôC�yô Cô8�ô 8ô*Ð!:ô *ô"Ð,ô "ô@�jô @ð "€ôB�Zô Bô;�9ô ;ô?˜,ô ?ôX˜ô Xô#˜^õ #r1   