
    Αi              
           S SK r S SKrS SKJrJr  S SKJr  0 SS\4_SS\4_SS	\4_S
S\4_SS\4_SS\4_SS\4_SS\4_SS\4_SS\4_SS\4_SS\4_SS\4_SS\4_S S!\4_S"S#\4_S$S%\4_S&\4S'\4S(\4S)\4S*\4S+\4S,\4S-\4S..Er	S/ r
S0 rg)1    N)	REMAINDERArgumentParser)	strtoboolPOD_IPhostPADDLE_MASTERmasterPADDLE_DEVICESdevicesPADDLE_NNODESnnodesPADDLE_RUN_MODErun_modePADDLE_LOG_LEVEL	log_levelPADDLE_LOG_OVERWRITElog_overwritePADDLE_SORT_IPsort_ipPADDLE_NPROC_PER_NODEnproc_per_nodePADDLE_JOB_IDjob_idPADDLE_RANKrankPADDLE_LOG_DIRlog_dirPADDLE_MAX_RESTARTmax_restartPADDLE_ELASTIC_LEVELelastic_levelPADDLE_ELASTIC_TIMEOUTelastic_timeoutPADDLE_SERVER_NUM
server_numPADDLE_TRAINER_NUMtrainer_numserverstrainers	gloo_port	with_gloo
start_portipsauto_parallel_configauto_cluster_config)PADDLE_SERVERS_ENDPOINTSPADDLE_TRAINERS_ENDPOINTSPADDLE_GLOO_PORTPADDLE_WITH_GLOOPADDLE_START_PORT
PADDLE_IPSPADDLE_AUTO_PARALLEL_CONFIGPADDLE_AUTO_CLUSTERc                  :   S Hx  n [         R                  R                  U 5      c  M%  [         R                  R                  U 5      [         R                  U  S3'   [        R
                  " SU  SU  S3[        S9  Mz     [         R                  R                  5       $ )N)
http_proxyhttps_proxy	_originalzUnset 'zM' to ensure stable NCCL communication in distributed training (backed up as 'z_original').)category)osenvirongetpopwarningswarnUserWarningcopy)	proxy_keys    k/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/distributed/launch/context/args_envs.py
fetch_envsrG   2   s{    2	::>>)$024**..2KBJJ)I./MM) %""+L:$ 3 ::??    c            
      R   [        5       n U R                  S5      nUR                  S[        S SS9  UR                  S[        SSS9  UR                  S[
        S	S
S9  UR                  S[        SSS9  UR                  S[        SSS9  UR                  S[        SSS9  UR                  S[        SSS9  UR                  S[        SSS9  UR                  S[
        S SS9  UR                  S[        SSS9  UR                  S[        S SS9  UR                  S[        S S!S9  UR                  S"S#S$S%[        S S&S9  UR                  S'[        S S(S9  UR                  S)[        S S*S9  UR                  S+[
        S,S-S9  UR                  S.[        S S/S9  UR                  S0[        S1S2S9  UR                  S3[        S4S59  UR                  S6[        S S7S9  UR                  S8[        S99  U R                  S:5      nUR                  S;[        S<S=S9  UR                  S>[        S<S?S9  UR                  S@[
        S SAS9  UR                  SB[
        S SCS9  UR                  SD[
        SESFS9  UR                  SG[        SSHS9  U R                  SI5      nUR                  SJ[
        SKSLS9  UR                  SM[
        S	SNS9  UR                  SO[
        SPSQS9  U R                  5       n[        [        R                  " SRS	5      5      nUS1:  a  [        US1   SS5      (       d   eXTS1   l        U$ )TNzBase Parametersz--masterz%the master/rendezvous server, ip:port)typedefaulthelpz--legacyFzuse legacy launchz--rankzthe node rankz--log_levelINFOzlog level. Default INFOz--log_overwritez'overwrite exits logfiles. Default Falsez	--sort_ipzrank node by ip. Default Falsez--enable_gpu_logTz2enable capture gpu log while running. Default Truez--nnodes1z)the number of nodes, i.e. pod/node numberz--nproc_per_nodez the number of processes in a podz	--log_dirlogz.the path for each process's log. Default ./logz
--run_modez+run mode of the job, collective/ps/ps-heterz--job_idrK   z%unique id of the job. Default defaultz	--devicesz--gpusz--npusz--xpusz'accelerate devices. as --gpus,npus,xpusz--hostzhost ipz--ipsz#nodes ips, e.g. 10.10.1.1,10.10.1.2z--start_porti  zfix port start withz--auto_parallel_configzGauto parallel config file absolute path, the file should be json formatz--auto_cluster_configr   z(auto parallel auto cluster config switchtraining_scriptzHthe full path of py script,followed by arguments for the training script)rJ   rL   z--auto_tuner_jsonzauto tuner json file pathtraining_script_args)nargszParameter-Server Parametersz	--servers zservers endpoints full listz
--trainersztrainers endpoints full listz--trainer_numznumber of trainersz--server_numznumber of serversz--gloo_portio  zgloo http portz--with_gloozuse gloo or notzElastic Parametersz--max_restart   z the times can restart. Default 3z--elastic_levelzHelastic level: -1 disable, 0 failed exit, peers hold, 1 internal restartz--elastic_timeout   z1seconds to wait before elastic job begin to trainPADDLE_TRAINER_IDr   )r   add_argument_groupadd_argumentstrr   intr   parse_known_argsr=   getenvhasattrr   )parser
base_groupps_groupelastic_groupargsenv_ranks         rF   
parse_argsre   ?   sG   F**+<=J4	   E8K   sB_   C6O   6	   -	   A	   8	   /	   =	   :	   4	   6   H39M2	   S$5J    V	   7	      (	   2)D(()FGH#r0M   31O   c46J   S$5H   C4D   C3D  
 --.BCM/	   W	   @	   ""$D2990"56H1}tAw''''QKrH   )r=   rA   argparser   r   paddle.utilsr   rZ   r[   env_args_mappingrG   re    rH   rF   <module>rj      s   
  . "vsmh_ y#& h_	
 
C( c* _i8 y), .4 h_ FC= y#& =#. _c2 0#6  ,,!" =#.#$ "+C 0",c!2$c*$c*&,#,$:C#@19=3 :
wrH   