§ &`ƒi­ãó&—ddlZddlZddlmZmZddlmZddlmZdZ dZ dee efdee effd „Z dee efdee effd „Z dee efdee effd „Zd e de fd „Zd e de fd„Zdee efdee effd„ZdS)éN)ÚAnyÚDict)Úget_ray_temp_dir)Ú cli_loggerz6The field {} is not supported for on-premise clusters.zlocal.cluster.nodeÚconfigÚreturncóB—tj|¦«}dD]E}| |¦«r.t |¦«}t j|¦«ŒFtiidœi|d<t|d<d|dvrt|¦«}nt|¦«}|S)z\ Prepare local cluster config for ingestion by cluster launcher and autoscaler. )Ú head_nodeÚ worker_nodesÚavailable_node_types)Ú node_configÚ resourcesr Úhead_node_typeÚcoordinator_addressÚprovider) ÚcopyÚdeepcopyÚgetÚunsupported_field_messageÚformatrÚabortÚLOCAL_CLUSTER_NODE_TYPEÚprepare_coordinatorÚprepare_manual)rÚfieldÚerr_msgs úx/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/autoscaler/_private/local/config.pyÚ prepare_localr sµ€õ Œ]˜6Ñ "Ô "€FØDð&ð&ˆØ :Š:eÑ Ô ð &Ý/×6Ò6°uÑ=Ô=ˆGÝ Ô ˜WÑ %Ô %Ð %øõ °À"Ð!EÐ!Eð&€FÐ !Ñ"õ 7€FÐ ÑØ  zÔ 2Ð2Ð2Ý$ VÑ,Ô,ˆˆå Ñ'Ô'ˆØ €MócóÌ—tj|¦«}d|vrtjd¦«|dt}| dd¦«|d<|d|d<|S)NÚ max_workersz[The field `max_workers` is required when using an automatically managed on-premise cluster.r Ú min_workersr)rrrrrÚpop)rÚ node_types rrr%sy€Ý Œ]˜6Ñ "Ô "€Fð˜FÐ"Ð"ÝÔð 8ñ ô ð ðÐ-Ô.Õ/FÔG€Ið &Ÿzšz¨-¸Ñ;Ô;€IˆmÑØ% mÔ4€IˆmÑØ €Mrc óP—tj|¦«}d|dvs d|dvrtjd¦«t |dd¦«}|dt }| d|¦«| d|¦«}|d}||kr$tjd|›d |›d |›d ¦«||d<n||d<||kr)tjd |›d |›d |›d ¦«||d<||d<n||d<||krtjd |›d|›d|›d¦«|S)ahValidates and sets defaults for configs of manually managed on-prem clusters. - Checks for presence of required `worker_ips` and `head_ips` fields. - Defaults min and max workers to the number of `worker_ips`. - Caps min and max workers at the number of `worker_ips`. - Writes min and max worker info into the single worker node type. Ú worker_ipsrÚhead_ipzbPlease supply a `head_ip` and list of `worker_ips`. Alternatively, supply a `coordinator_address`.r r!r"z%The value of `min_workers` supplied (z6) is greater than the number of available worker ips (z). Setting `min_workers=z`.z%The value of `max_workers` supplied (z). Setting `max_workers=z3) is less than the number of available worker ips (z ). At most z. Ray worker nodes will connect to the cluster.) rrrrÚlenrÚ setdefaultr#Úwarning)rÚnum_ipsr$r"r!s rrr6sç€õŒ]˜6Ñ "Ô "€FؘF :Ô.Ð.Ð.ؘ  Ô+Ð+Ð+åÔð =ñ ô ð õ&˜Ô$ \Ô2Ñ3Ô3€GØÐ-Ô.Õ/FÔG€Ià ×Òm WÑ-Ô-Ð-ð—*’*˜]¨GÑ4Ô4€KؘÔ'€KàWÒÐÝÔð 1°Kð 1ð 1Ø9@ð 1ð 1à%,ð 1ð 1ð 1ñ ô ð ð $+ˆ -Ñ Ð à#.ˆ -Ñ àWÒÐÝÔð 1°Kð 1ð 1Ø9@ð 1ð 1à%,ð 1ð 1ð 1ñ ô ð ð $+ˆ -Ñ Ø 'ˆˆ}ÑÐà#.ˆ -Ñ àWÒÐÝÔð T°Kð Tð TØ9@ð Tð Tà#ð Tð Tð Tñ ô ð ð €MrÚ cluster_namecó€—tj t¦«d |¦«¦«S)Nzcluster-{}.lock©ÚosÚpathÚjoinrr©r,s rÚ get_lock_pathr3ps.€Ý Œ7<Š<Õ(Ñ*Ô*Ð,=×,DÒ,DÀ\Ñ,RÔ,RÑ SÔ SÐSrcó€—tj t¦«d |¦«¦«S)Nzcluster-{}.stater.r2s rÚget_state_pathr5ts.€Ý Œ7<Š<Õ(Ñ*Ô*Ð,>×,EÒ,EÀlÑ,SÔ,SÑ TÔ TÐTrcó—|S)N©)rs rÚbootstrap_localr8xs€Ø €Mr)rr/ÚtypingrrÚray._common.utilsrÚ"ray.autoscaler._private.cli_loggerrrrÚstrrrrr3r5r8r7rrúr=s‚ðØ € € € Ø € € € ØÐÐÐÐÐÐÐà.Ð.Ð.Ð.Ð.Ð.Ø9Ð9Ð9Ð9Ð9Ð9àTÐà.Ðð˜$˜s C˜xœ.ð¨T°#°s°(¬^ððððð0  S¨# X¤ð°4¸¸S¸´>ððððð"7˜4  S œ>ð7¨d°3¸°8¬nð7ð7ð7ð7ðtT ðT¨ðTðTðTðTðU ðU¨ðUðUðUðUð˜D  c œNð¨t°C¸°H¬~ððððððr