&`i XddlmZmZmZmZmZddlmZeGddZdS))AnyDictListOptionalTuple) DeveloperAPIcVeZdZdZ ddeeded ed eee eefd ed ee ee fd edededefdZ ddededee ee fddfdZ ddededee ee fddfdZdefdZdede eefdedeefdZdS)CommandRunnerInterfaceaInterface to run commands on a remote cluster node. **Important**: This is an INTERNAL API that is only exposed for the purpose of implementing custom node providers. It is not allowed to call into CommandRunner methods from any Ray package outside the autoscaler, only to define new implementations for use with the "external" node provider option. Command runner instances are returned by provider.get_command_runner().NxFautocmdtimeout exit_on_fail port_forward with_outputenvironment_variablesrun_envssh_options_override_ssh_keyshutdown_after_runreturnc t)a@Run the given command on the cluster node and optionally get output. WARNING: the cloudgateway needs arguments of "run" function to be json dumpable to send them over HTTP requests. Args: cmd: The command to run. timeout: The command timeout in seconds. exit_on_fail: Whether to sys exit on failure. port_forward: List of (local, remote) ports to forward, or a single tuple. with_output: Whether to return output. environment_variables (Dict[str, str | int | Dict[str, str]): Environment variables that `cmd` should be run with. run_env: Options: docker/host/auto. Used in DockerCommandRunner to determine the run environment. ssh_options_override_ssh_key: if provided, overwrites SSHOptions class with SSHOptions(ssh_options_override_ssh_key). shutdown_after_run: if provided, shutdowns down the machine after executing the command with `sudo shutdown -h now`. NotImplementedError) selfrrrrrrrrrs q/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/autoscaler/command_runner.pyrunzCommandRunnerInterface.runs B"!sourcetargetoptionsct)zRsync files up to the cluster node. Args: source: The (local) source directory or file. target: The (remote) destination path. rrrr r!s r run_rsync_upz#CommandRunnerInterface.run_rsync_up5 "!rct)zRsync files down from the cluster node. Args: source: The (remote) source directory or file. target: The (local) destination path. rr#s rrun_rsync_downz%CommandRunnerInterface.run_rsync_down@r%rct)z4Return the command the user can use to open a shell.r)rs rremote_shell_command_strz/CommandRunnerInterface.remote_shell_command_strKs!!ras_head file_mounts sync_run_yetcdS)a?Used to run extra initialization commands. Args: as_head: Run as head image or worker. file_mounts: Files to copy to the head and worker nodes. sync_run_yet: Whether sync has been run yet. Returns: optional: Whether initialization is necessary. N)rr*r+r,s rrun_initzCommandRunnerInterface.run_initOs  r) Nr FNFNr r F)N)__name__ __module__ __qualname____doc__rstrintboolrrrobjectrrr$r'r)r/r.rrr r sOO""8<!=A,.#(!"!" c]!"!" !" tE#s(O45 !"  !" (S&[(9:!"!"'*!"!!" !"!"!"!"HMQ " " "#& "19$sCx.1I "  " " " "MQ " " "#& "19$sCx.1I "  " " " ""#""""    -1#s(^  KO  $       rr N) typingrrrrrray.util.annotationsrr r.rrr:s33333333333333------U U U U U U U U U U r