Fix deprecation warning

This commit is contained in:
David Soria Parra
2024-12-12 23:17:59 +00:00
parent 37f6a3229c
commit 52e69efa6f

View File

@@ -102,9 +102,9 @@ class SseServerTransport:
self._read_stream_writers[session_id] = read_stream_writer self._read_stream_writers[session_id] = read_stream_writer
logger.debug(f"Created new session with ID: {session_id}") logger.debug(f"Created new session with ID: {session_id}")
sse_stream_writer, sse_stream_reader = anyio.create_memory_object_stream( sse_stream_writer, sse_stream_reader = anyio.create_memory_object_stream[
0, dict[str, Any] dict[str, Any]
) ](0)
async def sse_writer(): async def sse_writer():
logger.debug("Starting SSE writer") logger.debug("Starting SSE writer")