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(10)

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(10)
