Qj dZddlmZddlmZddlmZddlm Z m Z ddl m Z m Z mZe rddlmZdZe d e Z d+ d,d ZGd deZGddeZGddeZGddeZGddeZGddeZGddeZGddeZGddeZGdd eZGd!d"eZ Gd#d$eZ!Gd%d&e!Z"Gd'd(e Z#Gd)d*eZ$y )-z Exceptions.) annotations)timeout) TracebackType) TYPE_CHECKINGTypeVar) ChannelErrorConnectionError ResourceError)Response)reraise KombuErrorOperationalError NotBoundErrorMessageStateError TimeoutError LimitExceededConnectionLimitExceededChannelLimitExceededr rVersionMismatchSerializerNotInstalledr SerializationError EncodeError DecodeError HttpErrorInconsistencyErrorBaseExceptionType)boundNcD|j|ur|j||)zReraise exception.) __traceback__with_traceback)tpvaluetbs L/var/www/html/truck-me/venv/lib/python3.12/site-packages/kombu/exceptions.pyr r s(  "$""2&& KceZdZdZy)r z)Common subclass for all Kombu exceptions.N__name__ __module__ __qualname____doc__r%r$r r &s3r%r ceZdZdZy)rz/Recoverable message transport connection error.Nr'r,r%r$rr*s9r%rceZdZdZy)rz(Failed to serialize/deserialize content.Nr'r,r%r$rr.s2r%rceZdZdZy)rzCannot encode object.Nr'r,r%r$rr2r%rceZdZdZy)rzCannot decode object.Nr'r,r%r$rr6r0r%rceZdZdZy)rz:Trying to call channel dependent method on unbound entity.Nr'r,r%r$rr:sDr%rceZdZdZy)rz*The message has already been acknowledged.Nr'r,r%r$rr>4r%rceZdZdZy)rzLimit exceeded.Nr'r,r%r$rrBsr%rceZdZdZy)rz4Maximum number of simultaneous connections exceeded.Nr'r,r%r$rrFs>r%rceZdZdZy)rz1Maximum number of simultaneous channels exceeded.Nr'r,r%r$rrJs;r%rceZdZdZy)rz$Library dependency version mismatch.Nr'r,r%r$rrNs.r%rceZdZdZy)rz>Support for the requested serialization type is not installed.Nr'r,r%r$rrRsHr%rceZdZdZy)ContentDisallowedz*Consumer does not allow this content-type.Nr'r,r%r$r;r;Vr4r%r;ceZdZdZy)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$rrZsr%rc@eZdZdZ d dfd ZddZxZS)rzHTTP Client Error.cR||_||_||_t||||yN)codemessageresponsesuper__init__)selfr@rArB __class__s r$rDzHttpError.__init__ds+      w1r%c$dj|S)NzHTTP {0.code}: {0.message})format)rEs r$__str__zHttpError.__str__os+22488r%)NN)r@intrAz str | NonerBzResponse | NonereturnNone)rKstr)r(r)r*r+rDrI __classcell__)rFs@r$rras> #$( 2 2 2" 2  29r%rr?)r!ztype[BaseExceptionType]r"rr#zTracebackType | NonerKr)%r+ __future__rsocketrrtypesrtypingrramqprr r kombu.asynchronous.httpr __all__ BaseExceptionrr Exceptionr rrrrrrrrrrrr;rrr,r%r$rXs "*)==0 /}E $   44:z:33 $  $ EJE5 5J?m?<=</j/IZI5.59 9r%