mirror of
https://github.com/vale981/ray
synced 2025-03-07 02:51:39 -05:00
10 lines
219 B
Python
10 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)
|