
    &`i                     8   d dl mZ d dlmZ d dlmZ d dlmZ  ed           G d de                      Z	 ed	           G d
 de	                      Z
 ed	           G d de	e                      Z ed	           G d de	                      ZdS )    )Optional)TaskCancelledError)DeploymentID)	PublicAPIstable)	stabilityc                       e Zd ZdS )RayServeExceptionN)__name__
__module____qualname__     h/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/serve/exceptions.pyr
   r
      s        Dr   r
   alphac                   T     e Zd ZdZdedef fdZdefdZedefd            Z	 xZ
S )BackPressureErrorzBRaised when max_queued_requests is exceeded on a DeploymentHandle.num_queued_requestsmax_queued_requestsc                 h    t                                          ||           d| d| d| _        d S )Nz9Request dropped due to backpressure (num_queued_requests=z, max_queued_requests=z).)super__init___message)selfr   r   	__class__s      r   r   zBackPressureError.__init__   sN    ,.ABBB;$7; ;#6; ; ; 	r   returnc                     | j         S Nr   r   s    r   __str__zBackPressureError.__str__   s
    }r   c                     | j         S r   r   r    s    r   messagezBackPressureError.message   s
    }r   )r   r   r   __doc__intr   strr!   propertyr#   __classcell__)r   s   @r   r   r      s        LL
C 
c 
 
 
 
 
 
         X    r   r   c                   2    e Zd ZdZddee         fdZd ZdS )RequestCancelledErrorz(Raise when a Serve request is cancelled.N
request_idc                     || _         d S r   _request_id)r   r+   s     r   r   zRequestCancelledError.__init__%   s    *4r   c                 *    | j         rd| j          dS dS )NzRequest z was cancelled.zRequest was cancelled.r-   r    s    r   r!   zRequestCancelledError.__str__(   s'     	,?d.????++r   r   )r   r   r   r$   r   r&   r   r!   r   r   r   r*   r*   !   sM        225 58C= 5 5 5 5, , , , ,r   r*   c                   :    e Zd ZdZdefdZedefd            ZdS )DeploymentUnavailableErrorzRaised when a Serve deployment is unavailable to receive requests.

    Currently this happens because the deployment failed to deploy.
    deployment_idc                     || _         d S r   _deployment_id)r   r2   s     r   r   z#DeploymentUnavailableError.__init__6   s    +r   r   c                     | j          dS )Nz, is unavailable because it failed to deploy.r4   r    s    r   r#   z"DeploymentUnavailableError.message9   s    %SSSSr   N)	r   r   r   r$   r   r   r'   r&   r#   r   r   r   r1   r1   /   sg         
,l , , , , T T T T XT T Tr   r1   N)typingr   ray.exceptionsr   ray.serve._private.commonr   ray.util.annotationsr   	Exceptionr
   r   r*   r1   r   r   r   <module>r<      sw         - - - - - - 2 2 2 2 2 2 * * * * * * X	 	 	 	 		 	 	 	 W    )   & W
, 
, 
, 
, 
,-/A 
, 
, 
, WT T T T T!2 T T T T Tr   