Skip to content

Commit 8f2cfca

Browse files
committed
ruff format
1 parent 4842cee commit 8f2cfca

File tree

2 files changed

+4
-12
lines changed

2 files changed

+4
-12
lines changed

src/mcp/shared/session.py

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -290,18 +290,12 @@ async def send_request(
290290
if scope.cancel_called:
291291
notification = CancelledNotification(
292292
method="notifications/cancelled",
293-
params=CancelledNotificationParams(
294-
requestId=request_id, reason="cancelled"
295-
),
293+
params=CancelledNotificationParams(requestId=request_id, reason="cancelled"),
296294
)
297295
await self._send_notification( # type: ignore
298296
notification, request_id
299297
)
300-
raise McpError(
301-
ErrorData(
302-
code=REQUEST_CANCELLED, message="Request cancelled"
303-
)
304-
)
298+
raise McpError(ErrorData(code=REQUEST_CANCELLED, message="Request cancelled"))
305299

306300
except TimeoutError:
307301
raise McpError(

tests/shared/test_session.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -175,9 +175,7 @@ async def make_request(client_session: ClientSession):
175175
except McpError:
176176
pytest.fail("Request should not have been cancelled")
177177

178-
async with create_connected_server_and_client_session(
179-
make_server()
180-
) as client_session:
178+
async with create_connected_server_and_client_session(make_server()) as client_session:
181179
async with anyio.create_task_group() as tg:
182180
tg.start_soon(make_request, client_session)
183181

@@ -191,4 +189,4 @@ async def make_request(client_session: ClientSession):
191189

192190
# Check server completed regardless
193191
with anyio.fail_after(1):
194-
await ev_tool_commplete.wait()
192+
await ev_tool_commplete.wait()

0 commit comments

Comments
 (0)