Fix deprecation warning
This commit is contained in:
parent
e98291e001
commit
edb37c8dc0
1 changed files with 3 additions and 3 deletions
|
|
@ -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")
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue