diff --git a/Lib/asyncio/queues.py b/Lib/asyncio/queues.py index 30004f2bc9bacd..8871cdc16c68b3 100644 --- a/Lib/asyncio/queues.py +++ b/Lib/asyncio/queues.py @@ -178,7 +178,7 @@ async def get(self): or if the queue has been shut down immediately. """ while self.empty(): - if self._is_shutdown and self.empty(): + if self._is_shutdown: raise QueueShutDown getter = self._get_loop().create_future() self._getters.append(getter)