Skip to content

Commit a92dea3

Browse files
ruff fixes
1 parent 628a6b1 commit a92dea3

File tree

2 files changed

+33
-23
lines changed

2 files changed

+33
-23
lines changed

src/mcp/client/session_group.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
from typing import Any, TypeAlias
1717

1818
import anyio
19-
from pydantic import BaseModel, AnyUrl
19+
from pydantic import AnyUrl, BaseModel
2020
from typing_extensions import Self
2121

2222
import mcp
@@ -303,7 +303,7 @@ async def _aggregate_components(
303303
resources_temp: dict[str, types.Resource] = {}
304304
tools_temp: dict[str, types.Tool] = {}
305305
tool_to_session_temp: dict[str, mcp.ClientSession] = {}
306-
resource_to_session_temp: dict[str, mcp.ClientSession] = {}
306+
resource_to_session_temp: dict[str, mcp.ClientSession] = {}
307307

308308
try:
309309
prompts = (await session.list_prompts()).prompts

tests/client/test_session_group.py

Lines changed: 31 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -405,22 +405,25 @@ async def test_read_resource_not_found(self):
405405
test_resource = types.Resource(
406406
name="test_resource",
407407
uri=AnyUrl("test://resource/1"),
408-
description="Test resource"
408+
description="Test resource",
409409
)
410-
410+
411411
# Mock all list methods
412-
mock_session.list_resources.return_value = types.ListResourcesResult(resources=[test_resource])
412+
mock_session.list_resources.return_value = types.ListResourcesResult(
413+
resources=[test_resource]
414+
)
413415
mock_session.list_prompts.return_value = types.ListPromptsResult(prompts=[])
414416
mock_session.list_tools.return_value = types.ListToolsResult(tools=[])
415-
417+
416418
# --- Test Setup ---
417419
group = ClientSessionGroup()
418-
group._session_exit_stacks[mock_session] = mock.AsyncMock(spec=contextlib.AsyncExitStack)
420+
group._session_exit_stacks[mock_session] = mock.AsyncMock(
421+
spec=contextlib.AsyncExitStack
422+
)
419423
await group.connect_with_session(
420-
types.Implementation(name="test_server", version="1.0.0"),
421-
mock_session
424+
types.Implementation(name="test_server", version="1.0.0"), mock_session
422425
)
423-
426+
424427
# --- Test Execution & Assertions ---
425428
with pytest.raises(ValueError, match="Resource not found: test://nonexistent"):
426429
await group.read_resource(AnyUrl("test://nonexistent"))
@@ -433,36 +436,43 @@ async def test_read_resource_success(self):
433436
test_resource = types.Resource(
434437
name="test_resource",
435438
uri=AnyUrl("test://resource/1"),
436-
description="Test resource"
439+
description="Test resource",
437440
)
438-
441+
439442
# Mock all list methods
440-
mock_session.list_resources.return_value = types.ListResourcesResult(resources=[test_resource])
443+
mock_session.list_resources.return_value = types.ListResourcesResult(
444+
resources=[test_resource]
445+
)
441446
mock_session.list_prompts.return_value = types.ListPromptsResult(prompts=[])
442447
mock_session.list_tools.return_value = types.ListToolsResult(tools=[])
443-
448+
444449
# Mock the session's read_resource method
445450
mock_read_result = mock.AsyncMock(spec=types.ReadResourceResult)
446-
mock_read_result.content = [types.TextContent(type="text", text="Resource content")]
451+
mock_read_result.content = [
452+
types.TextContent(type="text", text="Resource content")
453+
]
447454
mock_session.read_resource.return_value = mock_read_result
448-
455+
449456
# --- Test Setup ---
450457
group = ClientSessionGroup()
451-
group._session_exit_stacks[mock_session] = mock.AsyncMock(spec=contextlib.AsyncExitStack)
458+
group._session_exit_stacks[mock_session] = mock.AsyncMock(
459+
spec=contextlib.AsyncExitStack
460+
)
452461
await group.connect_with_session(
453-
types.Implementation(name="test_server", version="1.0.0"),
454-
mock_session
462+
types.Implementation(name="test_server", version="1.0.0"), mock_session
455463
)
456-
464+
457465
# Verify resource was added
458466
assert "test_resource" in group._resources
459467
assert group._resources["test_resource"] == test_resource
460468
assert "test_resource" in group._resource_to_session
461469
assert group._resource_to_session["test_resource"] == mock_session
462-
470+
463471
# --- Test Execution ---
464472
result = await group.read_resource(AnyUrl("test://resource/1"))
465-
473+
466474
# --- Assertions ---
467-
assert result.content == [types.TextContent(type="text", text="Resource content")]
475+
assert result.content == [
476+
types.TextContent(type="text", text="Resource content")
477+
]
468478
mock_session.read_resource.assert_called_once_with(AnyUrl("test://resource/1"))

0 commit comments

Comments
 (0)