We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 38fae72 + e07ee40 commit 35cc43cCopy full SHA for 35cc43c
1 file changed
src/app/endpoints/a2a.py
@@ -862,7 +862,7 @@ async def receive() -> MutableMapping[str, Any]:
862
logger.info("Handling A2A streaming request")
863
864
# Create queue for passing chunks from ASGI app to response generator
865
- chunk_queue: asyncio.Queue = asyncio.Queue()
+ chunk_queue: asyncio.Queue[Optional[bytes]] = asyncio.Queue()
866
867
async def streaming_send(message: dict[str, Any]) -> None:
868
"""Send callback that queues chunks for streaming."""
0 commit comments