diff --git a/src/a2a/server/events/event_consumer.py b/src/a2a/server/events/event_consumer.py index 71d7bd55..56f4c66f 100644 --- a/src/a2a/server/events/event_consumer.py +++ b/src/a2a/server/events/event_consumer.py @@ -130,6 +130,9 @@ async def consume_all(self) -> AsyncGenerator[Event]: except TimeoutError: # continue polling until there is a final event continue + except asyncio.TimeoutError: + # This class was made an alias of build-in TimeoutError after 3.11 + continue except QueueClosed: # Confirm that the queue is closed, e.g. we aren't on # python 3.12 and get a queue empty error on an open queue