Hello Community!! I’m very new to Ray and I tried the basic example available on Github, on Google Colab and its GPU. I edited the code a bit to notice its working. Here the code:
#EXAMPLE OF RAY
import ray
ray.init()
import time
@ray.remote
def f(x):
print(f"With Process {x}")
time.sleep(10)
return x * x
futures = [f.remote(i) for i in range(4)]
print(futures)
print(ray.get(futures))
ray.shutdown()
I noticed that at one particular time, only two parallel processes were running and others were waiting for them to finish.
I’m trying to run more than 2 parallel process.
Can anyone please give me a clue how to do it? Thanks in advance!!