oomblog.py

import ray

@ray.remote
def task_submitted_by_driver():
    futures = [leaf_task.remote() for _ in range(4)]
    ray.get(futures)
        
@ray.remote
def leaf_task():
    print("running leaf task")
    pass

tasks = [task_submitted_by_driver.remote() for _ in range(2)]

ray.get(tasks)