o Df @sndZddlmZddlmZddlmZddlm Z m Z ddl m Z m Z mZe r.ddlmZdZe d ed Z d2d3ddZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGd d!d!eZGd"d#d#eZGd$d%d%eZGd&d'd'eZGd(d)d)eZ Gd*d+d+eZ!Gd,d-d-e!Z"Gd.d/d/e Z#Gd0d1d1eZ$d S)4z Exceptions.) annotations)timeout) TracebackType) TYPE_CHECKINGTypeVar) ChannelErrorConnectionError ResourceError)Response)reraise KombuErrorOperationalError NotBoundErrorMessageStateError TimeoutError LimitExceededConnectionLimitExceededChannelLimitExceededrrVersionMismatchSerializerNotInstalledr SerializationError EncodeError DecodeError HttpErrorInconsistencyErrorBaseExceptionType)boundNtptype[BaseExceptionType]valuetbTracebackType | NonereturncCs|j|ur |||)zReraise exception.) __traceback__with_traceback)rrr r%I/home/ubuntu/webapp/venv/lib/python3.10/site-packages/kombu/exceptions.pyr s  r c@eZdZdZdS)r z)Common subclass for all Kombu exceptions.N__name__ __module__ __qualname____doc__r%r%r%r&r &r c@r')r z/Recoverable message transport connection error.Nr(r%r%r%r&r *r-r c@r')rz(Failed to serialize/deserialize content.Nr(r%r%r%r&r.r-rc@r')rzCannot encode object.Nr(r%r%r%r&r2r-rc@r')rzCannot decode object.Nr(r%r%r%r&r6r-rc@r')rz:Trying to call channel dependent method on unbound entity.Nr(r%r%r%r&r:r-rc@r')rz*The message has already been acknowledged.Nr(r%r%r%r&r>r-rc@r')rzLimit exceeded.Nr(r%r%r%r&rBr-rc@r')rz4Maximum number of simultaneous connections exceeded.Nr(r%r%r%r&rFr-rc@r')rz1Maximum number of simultaneous channels exceeded.Nr(r%r%r%r&rJr-rc@r')rz$Library dependency version mismatch.Nr(r%r%r%r&rNr-rc@r')rz>Support for the requested serialization type is not installed.Nr(r%r%r%r&rRr-rc@r')ContentDisallowedz*Consumer does not allow this content-type.Nr(r%r%r%r&r.Vr-r.c@r')rzData or environment has been found to be inconsistent. Depending on the cause it may be possible to retry the operation. Nr(r%r%r%r&rZr-rcs2eZdZdZ  ddfd d ZdddZZS)rzHTTP Client Error.Ncodeintmessage str | NoneresponseResponse | Noner"Nonecs&||_||_||_t|||dSN)r/r1r3super__init__)selfr/r1r3 __class__r%r&r8dszHttpError.__init__strcCs d|S)NzHTTP {0.code}: {0.message})format)r9r%r%r&__str__os zHttpError.__str__)NN)r/r0r1r2r3r4r"r5)r"r<)r)r*r+r,r8r> __classcell__r%r%r:r&ras  rr6)rrrrr r!r"r)%r, __future__rsocketrrtypesrtypingrramqprrr kombu.asynchronous.httpr __all__ BaseExceptionrr Exceptionr r rrrrrrrrrrr.rrr%r%r%r&s6