Method get

lib/sqlalchemy/util/queue.py:294–304

(self, block: bool = True, timeout: Optional[float] = None)

            raise Empty() from err

    def get(self, block: bool = True, timeout: Optional[float] = None) -> _T:
        if not block:
            return self.get_nowait()

        try:
            if timeout is not None:
                return await_(asyncio.wait_for(self._queue.get(), timeout))
            else:
                return await_(self._queue.get())
        except (asyncio.QueueEmpty, asyncio.TimeoutError) as err:
            raise Empty() from err