&`iW>0 ddlZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z ddl Z ddlmcmZddlmZmZddlmZmZddlmZmZmZddlmZddlmZdd lm Z dd l!m"Z"m#Z#dd l$m%Z% dTde e&de'de e&de e'e&fde#f dZ(de e&de e e&effdZ)dZ*dZ+de#de&de"fdZ,de#de&de"fdZ-e j.ddZ/e/0e j1de&dd de j1d e&dd d!e j1d"e&dd d#e j1d$e&dd d%e j1d&e&dd d'e j1d(e&dd d)e j1d*e&dd d+e j1d,d e2d-.e j1d/d e2d0.e j1d1d e3d2.e j1d3d e&d4.e j1d5d e'd d67eee j4d8d9d e j5:e%de e&de e&d;e e&de e&d?e e&d8e e&d@e e e3e2fdAe e e3e2fdBe e3dCe e&dDe'de e'e&fde e&fdEZ6e/0e j1de&dd de j4dFe&Geee%dHIde e&de&de e&de e'e&ffdJZ7e/0e j1de&dd de j1d5d e'd dK7e j4dFe&Geee%dHIde e&dDe'de&de e&de e'e&ff dLZ8e/0e j1de&dd de j4dFe&Geee%dHIde e&de&de e&de e'e&ffdMZ9e/0e j1de&dd de j4dFe&Ge j1dNdOd e'd dP7eee%dHIde e&de&dQe'de e&de e'e&ff dRZ:e/0e j1de&dd deee%dHIde e&de e&de e'e&ffdSZ;dS)UN) list2cmdline)AnyDictOptionalTupleUnion)get_or_create_event_loop load_class)parse_metadata_jsonparse_resources_json)add_click_logging_optionscf cli_logger)parse_runtime_env_args)add_common_job_options)redact_url_password) JobStatusJobSubmissionClient) PublicAPIFTaddresscreate_cluster_if_neededheadersverifyreturnct||t||}|}tjdt ||S)NrrzJob submission server address)r_handle_headers get_addressr labeled_valuer)rrrrclientclient_addresss q/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/dashboard/modules/job/cli.py_get_sdk_clientr#si ! (( F ''))N')<^)L)L Mc| dtjvrtjd}|J tj|S#t$r(}t d||d}~wwxYwdS)NRAY_JOB_HEADERSzbFailed to parse headers into JSON. Expected format: {{"KEY": "VALUE"}}, got {}, {})osenvironjsonloads Exception ValueErrorformat)rexcs r"rr/s, ::*./ :g&& &   CCI6SDD   4s: A,#A''A,c tjtjdt|ztj|tjdt|ztjdSN-)rnewlinesuccesslen success_msgs r"_log_big_success_msgr7?sssS---...{###sS---...r$c tjtjdt|ztj|tjdt|ztjdSr0)rr2errorr4r5s r"_log_big_error_msgr:GssS3{+++,,,[!!!S3{+++,,,r$r job_idc ||}|jtjkrt d|dn|jtjkrt jd|dn|jtjkr9td|d|j t j d|j dnDt j d|d |j|j t j d|j d|jS) NJob 'z ' succeededz ' was stoppedz' failedzStatus message: T no_formatzStatus for job 'z': ) get_job_infostatusr SUCCEEDEDr7STOPPEDrwarningFAILEDr:messageprint)r r;infos r"_log_job_statusrIOs   v & &D {i)))8V8889999  ) ) )868889999  ( ( (36333444 < #  > >>$ O O O O DFDDt{DDEEE < #  > >>$ O O O O ;r$cK||23d{V}t|d6t||S)N)end) tail_job_logsrGrI)r r;liness r" _tail_logsrOasi++F33e e4 66 * **s1jobcdS)z'Submit, stop, delete, or list Ray jobs.NrRr$r" job_cli_grouprShs  Dr$z --addresszAddress of the Ray cluster to connect to. Can also be specified using the RAY_API_SERVER_ADDRESS environment variable (falls back to RAY_ADDRESS).)typedefaultrequiredhelpz--job-idz*DEPRECATED: Use `--submission-id` instead.z--submission-idzMSubmission ID to specify for the job. If not provided, one will be generated.z --runtime-envz>Path to a local YAML file containing a runtime_env definition.z--runtime-env-jsonz'JSON-serialized runtime_env dictionary.z --working-dirzDirectory containing files that your job will run in. Can be a local directory or a remote URI to a .zip file (S3, GS, HTTP). If specified, this overrides the option in `--runtime-env`.z--metadata-jsonzT    + :r   "+VM(BJ66A 2:m?@AA '#-'#! 3 3/!5    $F/)    ++#%//+1  FAAAABBB  , ' ' @ @5666  " " @ @  RW%=V%=%=>> ? ? ? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ 7888  " " B B  RW%?v%?%?@@ A A A B B B B B B B B B B B B B B B 9:::  " " @ @  RW%=V%=%=>> ? ? ? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @$$&&K  {  a    L   233FF66**JY--- .-  $$$$     s~&(I+*F8 I+F I+ F *I+6*G, I+,G0 0I+3G0 4*I+*I I+I I+I I++I/2I/zjob-id)rTstable) stabilitycJt|||}t||dS)z`Queries for the current status of a job. Example: `ray job status ` rN)r#rIrr;rrr s r"rArAHs.4Wgf E E EFFF#####r$z*If set, will not wait for the job to exit.ct|||}tjd|d|||rdStjd|d ||}|t jt jt jhvrt||dStjd|tj d x) zMAttempts to stop a job. Example: `ray job stop ` rzAttempting to stop job ''NzWaiting for job 'z#' to exit (disable with --no-wait):Tz Job has not exited yet. Status: ri) r#rrGstop_jobget_job_statusrrCrBrErItimesleep)rrer;rrr rAs r"stoprfsDWgf E E EF9999::: OOF  O O O O   &&v.. i')NO O O FF + + + E  HHH I I I JqMMMr$ct|||}||tjd|ddS)aDeletes a stopped job and its associated data from memory. Only supported for jobs that are already in a terminal state. Fails with exit code 1 if the job is not already stopped. Does not delete job logs from disk. Submitting a job with the same submission ID as a previously deleted job is not supported and may lead to unexpected behavior. Example: ray job delete rr=z' deleted successfullyN)r# delete_jobrrGr}s r"deletersP@Wgf E E EF f;V;;;<<<<` rrzN)r#rrGpprintpformat list_jobs)rrrr s r"listrsL(Wgf E E EFV^F$4$4$6$6774HHHHHHr$)FNT)rs  ######44444444444444 222222222YXXXXXXXXXFFFFFFFFFFFF??????========****** &+!#  c]"c] $)    & Xc] xS#X/G     /$+0+#+)++++ U       ]      6    2      I    2    F      G    B    B        B    E  BE