How severe does this issue affect your experience of using Ray?
- Low: It annoys or frustrates me for a moment.
I want to use tqdm_ray to monitor progress on worker tasks I have submitted to the ray cluster.
import random from time import sleep import ray from ray.experimental import tqdm_ray @ray.remote def worker(bar: tqdm_ray.tqdm): dt = random.random() sleep(dt) bar.update(1) if __name__ == '__main__': n = 10 bar = tqdm_ray.tqdm(total=n) ray.get([worker.remote(bar) for _ in range(n)]) bar.close()
I would expect to see a single tqdm progress bar, that increments every time one of the worker tasks finishes. Instead I see the empty progress bar remaining at 0 and vanishing after all workers have completed.
What am I doing wrong?