Ë
    ‡\;jó  ã                   óö  — d dl Z d dlZ G d„ d«      Zedk(  �ra e j                  d¬«      Zej                  ded¬	«       ej                  d
ed¬	«       ej                  ded¬	«       ej                  ded¬	«       ej                  «       Z	e	j                  xs  ej                  d«      Ze	j                  xs  ej                  d«      Z ee	j                   j#                  d«      d    «      xs  e ej                  dd «      «      Z eee«      Ze	j&                  dk(  rej)                  e«       e	j&                  dk(  rej+                  «         ede	j&                  › d�«       ej/                  «        yy)é    Nc                   ó*   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zy)ÚCommandc                 óÈ   — dd l }|j                  d«      \  }}|j                  ||¬«      | _        d|z   | _        | j                  dz   | _        | j                  dz   | _        y )Nr   Ú:)ÚhostÚportz/paddle/z/nodesz/np)Úetcd3ÚsplitÚclientÚetcdÚprefixÚnode_prefixÚnp_path)ÚselfÚserverÚnamer	   Úsrvr   s         úcG:\00. PROJECTS\API\Inventory\templateJSON\kerjaOCR\Lib\site-packages\paddle/distributed/elastic.pyÚ__init__zCommand.__init__   sX   € Ûà—L‘L Ó%‰	ˆˆTØ—L‘L c°�LÓ5ˆŒ	à  4Ñ'ˆŒØŸ;™;¨Ñ1ˆÔØ—{‘{ UÑ*ˆ�ó    c                 óp   — | j                   j                  | j                  |› j                  d«      «       y )Nzlatin-1)r   Úputr   Úencode©r   Únps     r   Úset_npzCommand.set_np   s#   € Ø�	‰	�‰�d—l‘l r d§N¡N°9Ó$=Õ>r   c                 óx   — | j                   j                  | j                  «      d   �| j                  |«       yy)Nr   TF)r   Úgetr   r   r   s     r   Úscale_npzCommand.scale_np!   s/   € Ø�9‰9�=‰=˜Ÿ™Ó& qÑ)Ð5Ø�K‰K˜ŒOØØr   c                 óN   — | j                   j                  | j                  «       y ©N)r   Údelete_prefixr   ©r   s    r   ÚcleanzCommand.clean'   s   € Ø�	‰	×Ñ §¡Õ,r   c                 ó8   — | j                   j                  «        y r!   )r   Úcloser#   s    r   r&   zCommand.close*   s   € Ø�	‰	�‰Õr   N)Ú__name__Ú
__module__Ú__qualname__r   r   r   r$   r&   © r   r   r   r      s   „ ò+ò?òò-ór   r   Ú__main__zElastic Command)Údescriptionz--elastic_serverzetcd server host:port)ÚtypeÚhelpz--job_idzjob unique idz--npz9job pod/node number, need to be 'MIN' or 'MIN:MAX' formatÚactionzaction to takeÚPADDLE_ELASTIC_SERVERÚPADDLE_ELASTIC_JOB_IDr   ÚPADDLE_ELASTIC_NPÚscaler$   zaction z done)ÚargparseÚosr   r'   ÚArgumentParserÚparserÚadd_argumentÚstrÚ
parse_argsÚargsÚelastic_serverÚgetenvr   Újob_idr   Úintr   r
   Úcmdr/   r   r$   Úprintr&   r*   r   r   Ú<module>rB      sn  ðó Û 	÷ñ ð6 ˆzÓØ$ˆX×$Ñ$Ð1BÔC€FØ
×ÑØ Ð+Bð ô ð ×Ñ˜
¨°?ÐÔCØ
×ÑØØØHð ô ð
 ×Ñ˜ sÐ1AÐÔBà×ÑÓ€Dà× Ñ ÒF I B§I¡IÐ.EÓ$F€FØ�;‰;Ò<˜)˜"Ÿ)™)Ð$;Ó<€Dá	ˆT�W‰W�]‰]˜3Ó Ñ"Ó	#Ò	M¡s¨9¨2¯9©9Ð5HÈ!Ó+LÓ'M€Bá
�&˜$Ó
€Cà‡{�{�gÒØ�‰�RÔà‡{�{�gÒØ�	‰	Œá	ˆG�D—K‘K�= Ð
&Ô'à‡I�I…Kð= r   