mirror of
https://github.com/vale981/ray
synced 2025-03-08 19:41:38 -05:00
24 lines
510 B
Python
24 lines
510 B
Python
import click
|
|
import ray
|
|
import time
|
|
|
|
|
|
def num_alive_nodes():
|
|
n = 0
|
|
for node in ray.nodes():
|
|
if node["Alive"]:
|
|
n += 1
|
|
return n
|
|
|
|
|
|
@click.command()
|
|
@click.option("--num-nodes", required=True, type=int, help="The target number of nodes")
|
|
def wait_cluster(num_nodes: int):
|
|
ray.init(address="auto")
|
|
while num_alive_nodes() != num_nodes:
|
|
print(f"Waiting for nodes: {num_alive_nodes()}/{num_nodes}")
|
|
time.sleep(5)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
wait_cluster()
|