I want to check task is completed or not based on some id

Ray Core
1

How severe does this issue affect your experience of using Ray?

  • High: It blocks me to complete my task.
def run_gpu_intensive_task(data):
    if not ray.is_initialized():
        ray.init(address="ray_head:6385")
    # print(ray.available_resources)

    @ray.remote(num_gpus=1)
    def heavy_computation(data):
        import time  # Simulate a GPU-intensive task
        return data * 2

    result_ref = heavy_computation.remote(data)
    
    return ray.get(result_ref)

i don’t want to ray.get(result_ref) this is things block my fastapi main thread and i don’t know how can i check this task is completed or not with interval polling to the ray