Test zombie raylet processes

test.py

import ray

import numpy as np
import time


ray.init(address="auto")

@ray.remote
def f(x):
    time.sleep(0.1)
    return x

while len(ray.nodes()) < 4:
    time.sleep(1)
    print("waiting for cluster")

time.sleep(30)
assert all([node['Alive'] for node in ray.nodes()]), len(ray.nodes())

objs = [f.remote(np.zeros(int(5e5))) for _ in range(100)]
ray.get([f.remote(obj) for obj in objs])
print("done")