Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/__pycache__/exceptions.cpython-39.pyc
Ðазад
a t�h~# � @ sZ d Z ddlZddlmZmZmZmZ ddlmZ ddl m Z dZ ddl m Z dZdId d �ZG d d � d e�ZG d d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZeZG d d � d e�Z G d d � d e�Z G d!d"� d"e�Z G d#d$� d$e�Z G d%d&� d&e�Z G d'd(� d(e!e �Z"G d)d*� d*e �Z#G d+d,� d,e!e �Z$G d-d.� d.e �Z%G d/d0� d0e �Z&G d1d2� d2e �Z'G d3d4� d4e �Z(G d5d6� d6e �Z)G d7d8� d8e �Z*G d9d:� d:e+�Z,G d;d<� d<e-�Z.G d=d>� d>e/�Z0e0Z1G d?d@� d@e/�Z2G dAdB� dBe�Z3G dCdD� dDe3�Z4G dEdF� dFe3�Z5G dGdH� dHe�Z6dS )Ja� 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 C s |j |ur|�|��|�dS )zReraise exception.N)� __traceback__�with_traceback)�tp�value�tb� r. ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/exceptions.pyr j s r c @ s e Zd ZdZdS )r z#Base class for all Celery warnings.N��__name__� __module__� __qualname__�__doc__r. r. r. r/ r q s r c @ s e Zd ZdZdS )r z6send_task ignores :setting:`task_always_eager` option.Nr0 r. r. r. r/ r u s r c @ s e Zd ZdZdS )r z-Multiple workers are using the same nodename.Nr0 r. r. r. r/ r y s r c @ s e Zd ZdZdS )r zFixup related warning.Nr0 r. r. r. r/ r } s r c @ s e Zd ZdZdS )r zBCelery hasn't been configured, as no config module has been found.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z Potential security issue found.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z!Base class for all Celery errors.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z,Base class for task-related semi-predicates.Nr0 r. r. r. r/ r � s r c sF e Zd ZdZdZdZdZd � fdd� Zdd� Zdd � Z d d � Z � Z S ) r z The task is to be retried later.NFc sx ddl m} || _t|t�r,d | | _| _n t|�|r>||�nd | _| _|| _|| _ || _ t � j | ||fi |�� d S )Nr )� safe_repr) Zkombu.utils.encodingr5 �message� isinstance�str�exc�excsr( �when�is_eager�sig�super�__init__)�selfr6 r9 r; r< r= �kwargsr5 �� __class__r. r/ r? � s zRetry.__init__c C s( t | jtj�r d| j� d�S d| j� �S )Nzin �szat )r7 r; �numbers�Number�r@ r. r. r/ �humanize� s zRetry.humanizec C s6 | j r | j S | jr(d| �� � d| j� �S d| �� � �S )NzRetry �: )r6 r: rH rG r. r. r/ �__str__� s z Retry.__str__c C s | j | j| j| jffS �N)rC r6 r9 r; rG r. r. r/ � __reduce__� s zRetry.__reduce__)NNNFN) r1 r2 r3 r4 r6 r9 r; r? rH rJ rL � __classcell__r. r. rB r/ r � s � r c @ s e Zd ZdZdS )r z4A task can raise this to ignore doing state updates.Nr0 r. r. r. r/ r � s r c s* e Zd ZdZd� fdd� Zdd� Z� ZS ) r zAA task can raise this if it wants to reject/re-queue the message.NFc s || _ || _t� �||� d S rK )�reason�requeuer> r? )r@ rN rO rB r. r/ r? � s zReject.__init__c C s d| j � d| j� �S )Nzreject requeue=rI )rO rN rG r. r. r/ �__repr__� s zReject.__repr__)NF�r1 r2 r3 r4 r? rP rM r. r. rB r/ r � s r c @ s e Zd ZdZdS )r z(Celery is somehow improperly configured.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r zSecurity related exception.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r zTask related errors.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z.Task routed to a queue not in ``conf.queues``.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z?Found the end of a stream of data, but the data isn't complete.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdd� ZdS )r zThe task is not registered.c C s t �| �S rK )�UNREGISTERED_FMT�formatrG r. r. r/ rP � s zNotRegistered.__repr__N)r1 r2 r3 r4 rP r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z The task is already registered.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r zThe operation timed out.Nr0 r. r. r. r/ r � s r c s e Zd ZdZ� fdd�Z� ZS )r z.The tasks max restart limit has been exceeded.c s4 |� dg �| _|� dt� �| _t� j|i |�� d S )N� task_args� task_kwargs)�poprT �dictrU r> r? �r@ �argsrA rB r. r/ r? � s z MaxRetriesExceededError.__init__�r1 r2 r3 r4 r? rM r. r. rB r/ r � s r c @ s e Zd ZdZdS )r z2The task has been revoked, so no result available.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z8The task has invalid data or ain't properly constructed.Nr0 r. r. r. r/ r � s r c @ s e Zd ZdZdS )r z-A task part of the chord raised an exception.Nr0 r. r. r. r/ r s r c @ s e Zd ZdZdS )r# z Warning of pending deprecation.Nr0 r. r. r. r/ r# s r# c @ s e Zd ZdZdS )r$ zWarning of deprecation.Nr0 r. r. r. r/ r$ s r$ c @ s e Zd ZdZdS )r& z5Signals that the worker should terminate immediately.Nr0 r. r. r. r/ r& s r& c @ s e Zd ZdZdS )r% z7Signals that the worker should perform a warm shutdown.Nr0 r. r. r. r/ r% s r% c @ s e Zd ZdZdS )r z0An issue writing or reading to/from the backend.Nr0 r. r. r. r/ r s r c s( e Zd ZdZdd� Z� fdd�Z� ZS )r! z"An issue reading from the backend.c O s |� dd�| _d S )N�task_id� )�getr[ rX r. r. r/ r? ! s z BackendGetMetaError.__init__c s t � �� d | j S )N� task_id:)r> rP r[ rG rB r. r/ rP $ s z BackendGetMetaError.__repr__rQ r. r. rB r/ r! s r! c s( e Zd ZdZdd� Z� fdd�Z� ZS )r" z An issue writing to the backend.c O s |� dd�| _|� dd�| _d S )N�stater\ r[ )r] r_ r[ rX r. r. r/ r? + s zBackendStoreError.__init__c s t � �� d | j d | j S )Nz state:r^ )r> rP r_ r[ rG rB r. r/ rP / s zBackendStoreError.__repr__rQ r. r. rB r/ r" ( s r" c s e Zd ZdZ� fdd�Z� ZS )r' z6A general command exception which stores an exit code.c s t � j|d� || _d S )N)r6 )r> r? � exit_code)r@ r6 r` rB r. r/ r? 6 s z CeleryCommandException.__init__rZ r. r. rB r/ r' 3 s r' )N)7r4 rE Zbilliard.exceptionsr r r r Zclickr Zkombu.exceptionsr �__all__Zcelery.utils.serializationr( rR r � UserWarningr r r r r r � Exceptionr r r ZRetryTaskErrorr r r r r �KeyErrorr r r r r r r r r �PendingDeprecationWarningr# �DeprecationWarningr$ � SystemExitr& ZSystemTerminater% r r! r" r' r. r. r. r/ �<module> sR 5 ' *
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка