Skip to content

Commit 24a7ecf

Browse files
committed
fix fmt
1 parent f739155 commit 24a7ecf

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

src/agents/mcp/server.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,9 +11,9 @@
1111

1212
from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream
1313
from mcp import ClientSession, StdioServerParameters, Tool as MCPTool, stdio_client
14+
from mcp.client.session import MessageHandlerFnT
1415
from mcp.client.sse import sse_client
1516
from mcp.client.streamable_http import GetSessionIdCallback, streamablehttp_client
16-
from mcp.client.session import MessageHandlerFnT
1717
from mcp.shared.message import SessionMessage
1818
from mcp.types import CallToolResult, GetPromptResult, InitializeResult, ListPromptsResult
1919
from typing_extensions import NotRequired, TypedDict

tests/mcp/test_message_handler.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,16 @@
22

33
import anyio
44
import pytest
5+
from mcp.client.session import MessageHandlerFnT
56
from mcp.shared.message import SessionMessage
67
from mcp.types import InitializeResult
78

89
from agents.mcp.server import (
910
MCPServerSse,
10-
MCPServerStreamableHttp,
1111
MCPServerStdio,
12+
MCPServerStreamableHttp,
1213
_MCPServerWithClientSession,
1314
)
14-
from mcp.client.session import MessageHandlerFnT
1515

1616

1717
class _StubClientSession:
@@ -53,9 +53,8 @@ def __init__(self, handler: MessageHandlerFnT | None):
5353
def create_streams(self):
5454
@contextlib.asynccontextmanager
5555
async def _streams():
56-
send_stream, recv_stream = anyio.create_memory_object_stream[SessionMessage | Exception](
57-
1
58-
)
56+
send_stream, recv_stream = (
57+
anyio.create_memory_object_stream[SessionMessage | Exception](1))
5958
try:
6059
yield recv_stream, send_stream, None
6160
finally:

0 commit comments

Comments
 (0)