2020-02-24 21:18:53 -08:00
|
|
|
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())
|
2021-06-01 17:39:18 +02:00
|
|
|
time.sleep(10)
|