o `۷id e'd d?d@eee j4dAdBd e j5dCe%de e&de e&dDe e&dEe e&dFe e&dGe e&dHe e&dAe e&dIe e e3e2fdJe e e3e2fdKe e3dLe e&dMe e&dNe'de e'e&fde e&f dOdPZ6e/0e j1d$e&dd d%d&e j4dQe&dReee%dSdTde e&de&de e&de e'e&ffdUdVZ7e/0e j1d$e&dd d%d&e j1d>d e'd dWd@e j4dQe&dReee%dSdTde e&dNe'de&de e&de e'e&ff dXdYZ8e/0e j1d$e&dd d%d&e j4dQe&dReee%dSdTde e&de&de e&de e'e&ffdZd[Z9e/0e j1d$e&dd d%d&e j4dQe&dRe j1d\d]d e'd d^d@eee%dSdTde e&de&d_e'de e&de e'e&ff d`daZ:e/0e j1d$e&dd d%d&eee%dSdTde e&de e&de e'e&ffdbdcZ;dS)eN) 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_neededheadersverifyreturncCs0t||t||d}|}tdt||S)NrrzJob submission server address)r_handle_headers get_addressr labeled_valuer)rrrrclientclient_addressr S/home/ubuntu/vllm_env/lib/python3.10/site-packages/ray/dashboard/modules/job/cli.py_get_sdk_clientsr"c Cs^|durdtjvrtjd}|dur-zt|WSty,}ztd||d}~wwdS)NRAY_JOB_HEADERSzbFailed to parse headers into JSON. Expected format: {{"KEY": "VALUE"}}, got {}, {})osenvironjsonloads Exception ValueErrorformat)rexcr r r!r/s  rcCBttdt|t|tdt|tdSN-)rnewlinesuccesslen success_msgr r r!_log_big_success_msg?   r4cCr,r-)rr/errorr1r2r r r!_log_big_error_msgGr5r7rjob_idcCs||}|jtjkrtd|d|jS|jtjkr(td|d|jS|jtjkrIt d|d|j durFtj d|j dd|jSt d|d |j|j duretj d|j dd|jS) NJob 'z ' succeededz ' was stoppedz' failedzStatus message: T no_formatzStatus for job 'z': ) get_job_infostatusr SUCCEEDEDr4STOPPEDrwarningFAILEDr7messageprint)rr8infor r r!_log_job_statusOs      rEcs2||2z 3dHW}t|ddq6t||S)N)end) tail_job_logsrCrE)rr8linesr r r! _tail_logsas  rJjobcCsdS)z'Submit, stop, delete, or list Ray jobs.Nr r r r r! job_cli_grouphsrLz --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-jsonz` rN)r"rErr8rrrr r r!r=ksr=z*If set, will not wait for the job to exit.cCst|||d}td|d|||rdStd|d ||}|tjtjtjhvr9t ||dStd|t d q#) 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: rb) r"rrCstop_jobget_job_statusrr?r>rArEtimesleep)rr_r8rrrr=r r r!stops "     r{cCs.t|||d}||td|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 rr9z' deleted successfullyN)r" delete_jobrrCrur r r!deletes r}z-fz--followz)If set, follow the logs (like `tail -f`).followcCslt|||d}|}|r)t|dkrtt||dStd|ddStj| |ddddS) zMGets the logs of a job. Example: `ray job logs ` rrzs,       "          .     !     4