mirror of
https://github.com/wassname/ray.git
synced 2026-06-28 22:37:36 +08:00
Barak Michener
11 lines
219 B
Python
11 lines
219 B
Python
import ray
|
|
import time
|
|
|
|
ray.init(address="auto")
|
|
|
|
curr_nodes = 0
|
|
while not curr_nodes > 8:
|
|
print("Waiting for more nodes to come up: {}/{}".format(curr_nodes, 8))
|
|
curr_nodes = len(ray.nodes())
|
|
time.sleep(5)
|