
    Αi                        S SK r S SKr " S S5      r\S:X  Gac  \ R                  " SS9r\R                  S\SS	9  \R                  S
\SS	9  \R                  S\SS	9  \R                  S\SS	9  \R                  5       r	\	R                  =(       d    \R                  " S5      r\	R                  =(       d    \R                  " S5      r\" \	R                   R#                  S5      S    5      =(       d    \" \R                  " SS 5      5      r\" \\5      r\	R&                  S:X  a  \R)                  \5        \	R&                  S:X  a  \R+                  5         \" S\	R&                   S35        \R/                  5         gg)    Nc                   2    \ rS rSrS rS rS rS rS rSr	g)	Command   c                     SS K nUR                  S5      u  pEUR                  XES9U l        SU-   U l        U R                  S-   U l        U R                  S-   U l        g )Nr   :)hostportz/paddle/z/nodesz/np)etcd3splitclientetcdprefixnode_prefixnp_path)selfservernamer
   srvr	   s         Z/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/distributed/elastic.py__init__Command.__init__   sT    LL%	LLcL5	 4';;1{{U*    c                 p    U R                   R                  U R                  U R                  S5      5        g )Nzlatin-1)r   putr   encoder   nps     r   set_npCommand.set_np   s#    		dllrdNN9$=>r   c                 z    U R                   R                  U R                  5      S   b  U R                  U5        gg)Nr   TF)r   getr   r   r   s     r   scale_npCommand.scale_np!   s/    99==&q)5KKOr   c                 N    U R                   R                  U R                  5        g N)r   delete_prefixr   r   s    r   cleanCommand.clean'   s    		,r   c                 8    U R                   R                  5         g r%   )r   closer'   s    r   r+   Command.close*   s    		r   )r   r   r   r   N)
__name__
__module____qualname____firstlineno__r   r   r"   r(   r+   __static_attributes__ 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   cmdr7   r"   r(   printr+   r2   r   r   <module>rJ      sf    	 6 z$$1BCF
+B   
?C
H  
 s1ABD  FBII.E$FF;;<"))$;<D	TWW]]3"	#	Ms2995H!+L'MB
&$
C{{gR{{g			GDKK=
&'IIK= r   