o b²“iˆ ã@s>ddlmZmZmZmZmZddlmZeGdd„dƒƒZdS)é)ÚAnyÚDictÚListÚOptionalÚTuple)Ú DeveloperAPIc@sþeZdZdZ         d!deeded ed eee eefd ed ee ee fd edededefdd„Z d"dededee ee fddfdd„Z d"dededee ee fddfdd„Zdefdd„Zdede eefdedeefdd „ZdS)#ÚCommandRunnerInterfacea¿Interface 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().NéxFÚautoÚÚcmdÚtimeoutÚ exit_on_failÚ port_forwardÚ with_outputÚenvironment_variablesÚrun_envÚssh_options_override_ssh_keyÚshutdown_after_runÚreturnc Có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) Úselfr r rrrrrrr©rúQ/home/ubuntu/.local/lib/python3.10/site-packages/ray/autoscaler/command_runner.pyÚruns!zCommandRunnerInterface.runÚsourceÚtargetÚoptionscCr)z¨Rsync files up to the cluster node. Args: source: The (local) source directory or file. target: The (remote) destination path. r©rrrrrrrÚ run_rsync_up5ó z#CommandRunnerInterface.run_rsync_upcCr)z¬Rsync files down from the cluster node. Args: source: The (remote) source directory or file. target: The (local) destination path. rr rrrÚrun_rsync_down@r"z%CommandRunnerInterface.run_rsync_downcCr)z4Return the command the user can use to open a shell.r)rrrrÚremote_shell_command_strKsz/CommandRunnerInterface.remote_shell_command_strÚas_headÚ file_mountsÚ sync_run_yetcCsdS)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. Nr)rr%r&r'rrrÚrun_initOs zCommandRunnerInterface.run_init) Nr FNFNr r F)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚstrÚintÚboolrrrÚobjectrrr!r#r$r(rrrrrs| öþýüûúùø ÷ ö õ$ÿÿÿÿ þ ÿÿÿÿ þ ÿ ÿÿþrN) ÚtypingrrrrrÚray.util.annotationsrrrrrrÚs