o
    $it                     @   s.   d dl mZ d dlmZmZ G dd dZdS )    )Optional)	GcsClientNodeIDc                   @   s@   e Zd Zddedee fddZdefddZdefd	d
Z	dS )HealthCheckerN
gcs_clientlocal_node_idc                 C   s   || _ || _d S N)_gcs_client_local_node_id)selfr   r    r   a/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/dashboard/modules/reporter/utils.py__init__   s   
zHealthChecker.__init__returnc                    s0   | j d u rdS | j| j gdI d H }|d S )NF皙?r   )r
   r	   async_check_alive)r   livenessr   r   r   check_local_raylet_liveness   s
   
z)HealthChecker.check_local_raylet_livenessc                    s   | j g dI d H  dS )Nr   T)r	   r   )r   r   r   r   check_gcs_liveness   s   z HealthChecker.check_gcs_livenessr   )
__name__
__module____qualname__r   r   r   r   boolr   r   r   r   r   r   r      s    r   N)typingr   ray._rayletr   r   r   r   r   r   r   <module>   s    