We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e9426eb commit 7a758e3Copy full SHA for 7a758e3
src/a2a/server/events/event_consumer.py
@@ -17,7 +17,7 @@
17
18
19
# This is an alias to the exception for closed queue
20
-QueueClosed = asyncio.QueueEmpty
+QueueClosed: type[Exception] = asyncio.QueueEmpty
21
22
# When using python 3.13 or higher, the closed queue signal is QueueShutdown
23
if sys.version_info >= (3, 13):
src/a2a/server/events/event_queue.py
@@ -143,7 +143,7 @@ async def close(self) -> None:
143
144
self.queue.shutdown()
145
for child in self._children:
146
- child.close()
+ await child.close()
147
# Otherwise, join the queue
148
else:
149
tasks = [asyncio.create_task(self.queue.join())]
0 commit comments