mirror of
https://github.com/BerriAI/litellm.git
synced 2025-04-28 04:04:31 +00:00
fix linting errors
This commit is contained in:
parent
3ce0821314
commit
f600899ff7
2 changed files with 4 additions and 2 deletions
|
@ -30,8 +30,8 @@ router = APIRouter(
|
||||||
prefix="/mcp",
|
prefix="/mcp",
|
||||||
tags=["mcp"],
|
tags=["mcp"],
|
||||||
)
|
)
|
||||||
server = Server("litellm-mcp-server")
|
server: Server = Server("litellm-mcp-server")
|
||||||
sse = SseServerTransport("/mcp/sse/messages")
|
sse: SseServerTransport = SseServerTransport("/mcp/sse/messages")
|
||||||
|
|
||||||
########################################################
|
########################################################
|
||||||
############### MCP Server Routes #######################
|
############### MCP Server Routes #######################
|
||||||
|
|
|
@ -73,6 +73,8 @@ class SseServerTransport:
|
||||||
self._read_stream_writers[session_id] = read_stream_writer
|
self._read_stream_writers[session_id] = read_stream_writer
|
||||||
verbose_logger.debug(f"Created new session with ID: {session_id}")
|
verbose_logger.debug(f"Created new session with ID: {session_id}")
|
||||||
|
|
||||||
|
sse_stream_writer: MemoryObjectSendStream[dict[str, Any]]
|
||||||
|
sse_stream_reader: MemoryObjectReceiveStream[dict[str, Any]]
|
||||||
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]
|
0, dict[str, Any]
|
||||||
)
|
)
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue