U bh @svdZddlmZddlmZddlmZddlm Z m Z ddl m Z m Z mZe r\ddlmZdZe d ed Zd/d d d d dddZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdd 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#Gd-d.d.eZ$d S)0z Exceptions.) annotations)timeout) TracebackType) TYPE_CHECKINGTypeVar) ChannelErrorConnectionError ResourceError)Response)reraise KombuErrorOperationalError NotBoundErrorMessageStateError TimeoutError LimitExceededConnectionLimitExceededChannelLimitExceededrrVersionMismatchSerializerNotInstalledr SerializationError EncodeError DecodeError HttpErrorInconsistencyErrorBaseExceptionType)boundNztype[BaseExceptionType]zTracebackType | None)tpvaluetbreturncCs|j|k r|||dS)zReraise exception.N) __traceback__with_traceback)rrrr#4/tmp/pip-unpacked-wheel-earovzxb/kombu/exceptions.pyr s  r c@seZdZdZdS)r z)Common subclass for all Kombu exceptions.N__name__ __module__ __qualname____doc__r#r#r#r$r &sr c@seZdZdZdS)r z/Recoverable message transport connection error.Nr%r#r#r#r$r *sr c@seZdZdZdS)rz(Failed to serialize/deserialize content.Nr%r#r#r#r$r.src@seZdZdZdS)rzCannot encode object.Nr%r#r#r#r$r2src@seZdZdZdS)rzCannot decode object.Nr%r#r#r#r$r6src@seZdZdZdS)rz:Trying to call channel dependent method on unbound entity.Nr%r#r#r#r$r:src@seZdZdZdS)rz*The message has already been acknowledged.Nr%r#r#r#r$r>src@seZdZdZdS)rzLimit exceeded.Nr%r#r#r#r$rBsrc@seZdZdZdS)rz4Maximum number of simultaneous connections exceeded.Nr%r#r#r#r$rFsrc@seZdZdZdS)rz1Maximum number of simultaneous channels exceeded.Nr%r#r#r#r$rJsrc@seZdZdZdS)rz$Library dependency version mismatch.Nr%r#r#r#r$rNsrc@seZdZdZdS)rz>Support for the requested serialization type is not installed.Nr%r#r#r#r$rRsrc@seZdZdZdS)ContentDisallowedz*Consumer does not allow this content-type.Nr%r#r#r#r$r*Vsr*c@seZdZdZdS)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$rZsrcs<eZdZdZddddddfdd Zd d d d ZZS)rzHTTP Client Error.Nintz str | NonezResponse | NoneNone)codemessageresponser cs&||_||_||_t|||dS)N)r-r.r/super__init__)selfr-r.r/ __class__r#r$r1dszHttpError.__init__str)r cCs d|S)NzHTTP {0.code}: {0.message})format)r2r#r#r$__str__oszHttpError.__str__)NN)r&r'r(r)r1r7 __classcell__r#r#r3r$ras  r)N)%r) __future__rsocketrrtypesrtypingrrZamqprrr Zkombu.asynchronous.httpr __all__ BaseExceptionrr Exceptionr r rrrrrrrrrrr*rrr#r#r#r$s4