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 2c1849e commit e4dd605Copy full SHA for e4dd605
src/a2a/server/events/event_consumer.py
@@ -15,14 +15,8 @@
15
from a2a.utils.errors import ServerError
16
from a2a.utils.telemetry import SpanKind, trace_class
17
18
-# This is an alias to the execption for closed queue
19
-QueueClosed = asyncio.QueueEmpty
20
21
-# When using python 3.13 or higher, the closed queue signal is QueueShutdown
22
-if sys.version_info >= (3, 13):
23
- QueueClosed = asyncio.QueueShutDown
24
-
25
-# This is an alias to the exception for closed queue
+# This is an alias to the execption for closed queue
26
QueueClosed = asyncio.QueueEmpty
27
28
# When using python 3.13 or higher, the closed queue signal is QueueShutdown
0 commit comments