diff --git a/python/ray/experimental/queue.py b/python/ray/experimental/queue.py index 01f4fda3e..d0adcd6c7 100644 --- a/python/ray/experimental/queue.py +++ b/python/ray/experimental/queue.py @@ -36,7 +36,7 @@ class Queue: def empty(self): """Whether the queue is empty.""" - return ray.get(self.actor.qsize.remote()) + return ray.get(self.actor.empty.remote()) def full(self): """Whether the queue is full."""