mirror of
https://github.com/wassname/ray.git
synced 2026-06-28 12:10:40 +08:00
[autoscaler] Move attach helper text under exec_cluster (#3920)
## What do these changes do? Moves the attach command helper from cli commands to the actual `exec_cluster` function.
This commit is contained in:
committed by
Richard Liaw
parent
62a0a7bdc7
commit
b9eed2e86c
@@ -605,21 +605,6 @@ def submit(cluster_config_file, screen, tmux, stop, start, cluster_name,
|
||||
exec_cluster(cluster_config_file, cmd, screen, tmux, stop, False,
|
||||
cluster_name, port_forward)
|
||||
|
||||
if tmux or screen:
|
||||
attach_command_parts = ["ray attach", cluster_config_file]
|
||||
if cluster_name is not None:
|
||||
attach_command_parts.append(
|
||||
"--cluster-name={}".format(cluster_name))
|
||||
if tmux:
|
||||
attach_command_parts.append("--tmux")
|
||||
elif screen:
|
||||
attach_command_parts.append("--screen")
|
||||
|
||||
attach_command = " ".join(attach_command_parts)
|
||||
attach_info = "Use `{}` to check on command status.".format(
|
||||
attach_command)
|
||||
logger.info(attach_info)
|
||||
|
||||
|
||||
@cli.command()
|
||||
@click.argument("cluster_config_file", required=True, type=str)
|
||||
@@ -651,26 +636,9 @@ def submit(cluster_config_file, screen, tmux, stop, start, cluster_name,
|
||||
"--port-forward", required=False, type=int, help="Port to forward.")
|
||||
def exec_cmd(cluster_config_file, cmd, screen, tmux, stop, start, cluster_name,
|
||||
port_forward):
|
||||
assert not (screen and tmux), "Can specify only one of `screen` or `tmux`."
|
||||
|
||||
exec_cluster(cluster_config_file, cmd, screen, tmux, stop, start,
|
||||
cluster_name, port_forward)
|
||||
|
||||
if tmux or screen:
|
||||
attach_command_parts = ["ray attach", cluster_config_file]
|
||||
if cluster_name is not None:
|
||||
attach_command_parts.append(
|
||||
"--cluster-name={}".format(cluster_name))
|
||||
if tmux:
|
||||
attach_command_parts.append("--tmux")
|
||||
elif screen:
|
||||
attach_command_parts.append("--screen")
|
||||
|
||||
attach_command = " ".join(attach_command_parts)
|
||||
attach_info = "Use `{}` to check on command status.".format(
|
||||
attach_command)
|
||||
logger.info(attach_info)
|
||||
|
||||
|
||||
@cli.command()
|
||||
@click.argument("cluster_config_file", required=True, type=str)
|
||||
|
||||
Reference in New Issue
Block a user