
    Vh                         d dl mZmZ 	  G d de      Z G d de      Z G d de      Z G d d	e      Z G d
 de      Z	 G d de      Z
 G d de      Z G d d      Z G d d      Zy)    )AnyOptionalc                   $     e Zd ZdZd fdZ xZS )EtcdStubErrorzCCustom exception to indicate that the real etcd module is required.c                 $    t         |   d       y )Nz0The 'etcd' module is required but not installed.)super__init__)self	__class__s    _/home/dcms/DCMS/lib/python3.12/site-packages/torch/distributed/elastic/rendezvous/_etcd_stub.pyr	   zEtcdStubError.__init__   s    KL    returnN)__name__
__module____qualname____doc__r	   __classcell__)r   s   @r   r   r      s    MM Mr   r   c                        e Zd ZdededdfdZy)EtcdAlreadyExistargskwargsr   Nc                     t         Nr   r
   r   r   s      r   r	   zEtcdAlreadyExist.__init__       r   r   r   r   r   r	    r   r   r   r          c S T r   r   c                        e Zd ZdededdfdZy)EtcdCompareFailedr   r   r   Nc                     t         r   r   r   s      r   r	   zEtcdCompareFailed.__init__   r   r   r   r   r   r   r"   r"      r    r   r"   c                        e Zd ZdededdfdZy)EtcdKeyNotFoundr   r   r   Nc                     t         r   r   r   s      r   r	   zEtcdKeyNotFound.__init__$   r   r   r   r   r   r   r%   r%   #   r    r   r%   c                        e Zd ZdededdfdZy)EtcdWatchTimedOutr   r   r   Nc                     t         r   r   r   s      r   r	   zEtcdWatchTimedOut.__init__)   r   r   r   r   r   r   r(   r(   (   r    r   r(   c                        e Zd ZdededdfdZy)EtcdEventIndexClearedr   r   r   Nc                     t         r   r   r   s      r   r	   zEtcdEventIndexCleared.__init__.   r   r   r   r   r   r   r+   r+   -   r    r   r+   c                        e Zd ZdededdfdZy)EtcdExceptionr   r   r   Nc                     t         r   r   r   s      r   r	   zEtcdException.__init__3   r   r   r   r   r   r   r.   r.   2   r    r   r.   c                       e Zd ZddZy)
EtcdResultNc                     t         r   r   )r
   s    r   r	   zEtcdResult.__init__8   r   r   r   )r   r   r   r	   r   r   r   r1   r1   7   s    r   r1   c                   |    e Zd ZdededdfdZdeddfdZ	 ddeded	ee   deddf
d
Z		 ddededed	ee   ddf
dZ
y)Clientr   r   r   Nc                     t         r   r   r   s      r   r	   zClient.__init__=   r   r   keyc                     t         r   r   )r
   r6   s     r   readzClient.read@   r   r   valuettlc                     t         r   r   )r
   r6   r9   r:   r   s        r   writezClient.writeC   
     r   
prev_valuec                     t         r   r   )r
   r6   r9   r>   r:   s        r   test_and_setzClient.test_and_setH   r=   r   r   )r   r   r   r   r	   strr8   r   intr<   r@   r   r   r   r4   r4   <   s    c S T    :>")1#IL	 KO"03:B3-	r   r4   N)typingr   r   ImportErrorr   	Exceptionr   r"   r%   r(   r+   r.   r1   r4   r   r   r   <module>rF      sy    !MK My 
	 
i 
	 
I 
I 
 
 r   