hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[Autoscaler] Change poll interval to 5 sec when checking VMs status (#10462)

Browse source
This commit is contained in:
Yiran Wang 2020-09-15 17:23:29 -07:00 • committed by GitHub
parent 65065cc19d
commit c198869721
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
python/ray/autoscaler/commands.py
View file

@ -47,6 +47,8 @@ redis_client = None
RUN_ENV_TYPES = ["auto", "host", "docker"]
POLL_INTERVAL = 5
def _redis():
global redis_client
@ -379,10 +381,11 @@ def teardown_cluster(config_file: str, yes: bool, workers_only: bool,
cf.bold(len(A)),
_tags=dict(interval="1s"))
time.sleep(1) # todo: interval should be a variable
time.sleep(
POLL_INTERVAL) # todo: interval should be a variable
A = remaining_nodes()
cli_logger.print("{} nodes remaining after 1 second.",
cf.bold(len(A)))
cli_logger.print("{} nodes remaining after {} second(s).",
cf.bold(len(A)), POLL_INTERVAL)
cli_logger.success("No nodes remaining.")
finally:
provider.cleanup()
@ -427,7 +430,7 @@ def kill_node(config_file, yes, hard, override_cluster_name):
_exec(updater, "ray stop", False, False)
time.sleep(5)
time.sleep(POLL_INTERVAL)
if config.get("provider", {}).get("use_internal_ips", False) is True:
node_ip = provider.internal_ip(node)
@ -594,7 +597,7 @@ def get_or_create_head_node(config,
if len(nodes) == 1:
head_node = nodes[0]
break
time.sleep(1)
time.sleep(POLL_INTERVAL)
cli_logger.newline()
with cli_logger.group(