de46464aa3595c0fcb622ceaf2248eb9266e46e8,python/ray/experimental/queue.py,Queue,get,#Queue#Any#Any#,77

Before Change

        elif timeout is None:
            // Polling
            // Use a not_empty condition variable or return a promise?
            success, item = ray.get(self.actor.get.remote())
            while not success:
                // Consider adding time.sleep here
                success, item = ray.get(self.actor.get.remote())
        elif timeout < 0:

After Change

            ValueError if timeout is negative.
        
        if not block:
            try:
                return ray.get(self.actor.get_nowait.remote())
            except asyncio.QueueEmpty:
                raise Empty
        else:
            if timeout is not None and timeout < 0:
                raise ValueError(""timeout" must be a non-negative number")
            else:

Instances