&`i::ddlZddlZddlZddlZddlZddlZddlmZmZdZ da da dZ de fdZd Zde fd ZGd d eZejd ejdejdejddZddZeddfdZeddfdZdZdS)N)cf cli_loggerFTctSN_redirect_output/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/autoscaler/_private/subprocess_output_util.pyis_output_redirectedr s r valc |adS)zChoose between logging to a temporary file and to `sys.stdout`. The default is to log to a file. Args: val: If true, subprocess output will be redirected to a temporary file. Nrrs r set_output_redirectedrsr ctSr_allow_interactiver r r does_allow_interactiver!s r c |adS)zChoose whether to pass on stdin to running commands. The default is to pipe stdin and close it immediately. Args: val: If true, stdin will be passed to commands. Nrrs r set_allow_interactiver%sr c eZdZdfd ZxZS)ProcessRunnerErrorNc tt|d|||||||_||_||_||_dS)Nz0{} (discovered={}): type={}, code={}, command={})superr__init__formatmsg_typecodecommand special_case)selfmsgrrr r! __class__s r rzProcessRunnerError.__init__2si  $''00 > E E\8T7     !   (r )NNN)__name__ __module__ __qualname__r __classcell__)r$s@r rr1s= ) ) ) ) ) ) ) ) ) )r rzH\s*Warning: Permanently added '.+' \(.+\) to the list of known hosts.\s*z%\s*Shared connection to .+ closed.\s*z:\s*ssh: connect to host .+ port .+: Operation timed out\s*z9\s*ssh: connect to host .+ port .+: Connection refused\s*)known_host_updateconnection_closedtimeout conn_refusedcXd} |}||dkrn|ddkr |dd}|std|Xtd||td|zd }td ||td |zd }td |t j||(|t jkr||dz&|S)aRead and process a subprocess output stream. The goal is to find error messages and respond to them in a clever way. Currently just used for SSH messages (CONN_REFUSED, TIMEOUT, etc.), so the user does not get confused by these. Ran in a thread each for both `stdout` and `stderr` to allow for cross-platform asynchronous IO. Note: `select`-based IO is another option, but Windows has no support for `select`ing pipes, and Linux support varies somewhat. Spefically, Older *nix systems might also have quirks in how they handle `select` on pipes. Args: f: File object for the stream. output_file: File object to which filtered output is written. is_stdout (bool): When `is_stdout` is `False`, the stream is assumed to be `stderr`. Different error message detectors are used, and the output is displayed to the user unless it matches a special case (e.g. SSH timeout), in which case this is left up to the caller. NT r*r+z:Bug: ssh_timeout conflicts with another special codition: ssh_timeoutr,z?Bug: ssh_conn_refused conflicts with another special codition: ssh_conn_refusedr)) readline_ssh_output_regexes fullmatch ValueErrorrerror subprocessDEVNULLwrite)f output_file is_stdoutdetected_special_caselines r _read_subprocess_streamr@Oss4!<+zz|| <42::  8t  9D, #"#67AA$GGS "9-77==I )4$-/DE )6%">2<s r _run_and_process_outputrasOv!oO   ;%9%;%;;;:;; ##  $)=)?)?$ >Z77(( ! )         @  999999   A . . .0 ($OO';$,M%OO';%,M       FFHHH$1$8$8$:$: !##%%1(4 %0 )6(<(<(>(>%|a)$(!6 !!)$(!1 s *&**& )&.&.-      ! !& )  -     w||   ! !#5#<# GC'' ( (     ""r )F)rhrer8rgrkrm"ray.autoscaler._private.cli_loggerrrrwr rr boolrrr Exceptionrcompiler4r@rarurr r r rs   ======== t     t     ) ) ) ) ) ) ) ) $W$$LMMrzIBJD  Y!Y!Y!Y!~ P P P P h#550000f3#3#3#3#3#r