modelcontextprotocol/python-sdk
Watch
1
0
Fork
You've already forked python-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: bump ruff (#1085)

Browse source
This commit is contained in:
Marcelo Trylesinski 2025-07-04 10:01:17 +02:00 • committed by GitHub
commit 9301924f44
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
11 changed files with 56 additions and 57 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/mcp/cli/claude.py
View file

@ -35,7 +35,7 @@ def get_uv_path() -> str:
uv_path = shutil.which("uv")
if not uv_path:
logger.error(
"uv executable not found in PATH, falling back to 'uv'. " "Please ensure uv is installed and in your PATH"
"uv executable not found in PATH, falling back to 'uv'. Please ensure uv is installed and in your PATH"
)
return "uv" # Fall back to just "uv" if not found
return uv_path

12
src/mcp/cli/cli.py
View file

@ -150,10 +150,10 @@ def _import_server(file: Path, server_object: str | None = None):
True if it's supported.
"""
if not isinstance(server_object, FastMCP):
logger.error(f"The server object {object_name} is of type " f"{type(server_object)} (expecting {FastMCP}).")
logger.error(f"The server object {object_name} is of type {type(server_object)} (expecting {FastMCP}).")
if isinstance(server_object, LowLevelServer):
logger.warning(
"Note that only FastMCP server is supported. Low level " "Server class is not yet supported."
"Note that only FastMCP server is supported. Low level Server class is not yet supported."
)
return False
return True
@ -164,7 +164,7 @@ def _import_server(file: Path, server_object: str | None = None):
for name in ["mcp", "server", "app"]:
if hasattr(module, name):
if not _check_server_object(getattr(module, name), f"{file}:{name}"):
logger.error(f"Ignoring object '{file}:{name}' as it's not a valid " "server object")
logger.error(f"Ignoring object '{file}:{name}' as it's not a valid server object")
continue
return getattr(module, name)
@ -269,7 +269,7 @@ def dev(
npx_cmd = _get_npx_command()
if not npx_cmd:
logger.error(
"npx not found. Please ensure Node.js and npm are properly installed " "and added to your system PATH."
"npx not found. Please ensure Node.js and npm are properly installed and added to your system PATH."
)
sys.exit(1)
@ -371,7 +371,7 @@ def install(
typer.Option(
"--name",
"-n",
help="Custom name for the server (defaults to server's name attribute or" " file name)",
help="Custom name for the server (defaults to server's name attribute or file name)",
),
] = None,
with_editable: Annotated[
@ -445,7 +445,7 @@ def install(
name = server.name
except (ImportError, ModuleNotFoundError) as e:
logger.debug(
"Could not import server (likely missing dependencies), using file" " name",
"Could not import server (likely missing dependencies), using file name",
extra={"error": str(e)},
)
name = file.stem

2
src/mcp/client/session.py
View file

@ -168,7 +168,7 @@ class ClientSession(
)
if result.protocolVersion not in SUPPORTED_PROTOCOL_VERSIONS:
raise RuntimeError("Unsupported protocol version from the server: " f"{result.protocolVersion}")
raise RuntimeError(f"Unsupported protocol version from the server: {result.protocolVersion}")
await self.send_notification(
types.ClientNotification(types.InitializedNotification(method="notifications/initialized"))

4
src/mcp/client/sse.py
View file

@ -83,7 +83,7 @@ async def sse_client(
or url_parsed.scheme != endpoint_parsed.scheme
):
error_msg = (
"Endpoint origin does not match " f"connection origin: {endpoint_url}"
f"Endpoint origin does not match connection origin: {endpoint_url}"
)
logger.error(error_msg)
raise ValueError(error_msg)
@ -125,7 +125,7 @@ async def sse_client(
),
)
response.raise_for_status()
logger.debug("Client message sent successfully: " f"{response.status_code}")
logger.debug(f"Client message sent successfully: {response.status_code}")
except Exception as exc:
logger.error(f"Error in post_writer: {exc}")
finally:

2
src/mcp/server/auth/handlers/authorize.py
View file

@ -33,7 +33,7 @@ class AuthorizationRequest(BaseModel):
state: str | None = Field(None, description="Optional state parameter")
scope: str | None = Field(
None,
description="Optional scope; if specified, should be " "a space-separated list of scope strings",
description="Optional scope; if specified, should be a space-separated list of scope strings",
)
resource: str | None = Field(
None,

2
src/mcp/server/auth/handlers/register.py
View file

@ -72,7 +72,7 @@ class RegistrationHandler:
return PydanticJSONResponse(
content=RegistrationErrorResponse(
error="invalid_client_metadata",
error_description="grant_types must be authorization_code " "and refresh_token",
error_description="grant_types must be authorization_code and refresh_token",
),
status_code=400,
)

8
src/mcp/server/auth/handlers/token.py
View file

@ -119,9 +119,7 @@ class TokenHandler:
return self.response(
TokenErrorResponse(
error="unsupported_grant_type",
error_description=(
f"Unsupported grant type (supported grant types are " f"{client_info.grant_types})"
),
error_description=(f"Unsupported grant type (supported grant types are {client_info.grant_types})"),
)
)
@ -166,7 +164,7 @@ class TokenHandler:
return self.response(
TokenErrorResponse(
error="invalid_request",
error_description=("redirect_uri did not match the one " "used when creating auth code"),
error_description=("redirect_uri did not match the one used when creating auth code"),
)
)
@ -222,7 +220,7 @@ class TokenHandler:
return self.response(
TokenErrorResponse(
error="invalid_scope",
error_description=(f"cannot request scope `{scope}` " "not provided by refresh token"),
error_description=(f"cannot request scope `{scope}` not provided by refresh token"),
)
)

4
src/mcp/server/fastmcp/server.py
View file

@ -390,7 +390,7 @@ class FastMCP:
# Check if user passed function directly instead of calling decorator
if callable(name):
raise TypeError(
"The @tool decorator was used incorrectly. " "Did you forget to call it? Use @tool() instead of @tool"
"The @tool decorator was used incorrectly. Did you forget to call it? Use @tool() instead of @tool"
)
def decorator(fn: AnyFunction) -> AnyFunction:
@ -497,7 +497,7 @@ class FastMCP:
if uri_params != func_params:
raise ValueError(
f"Mismatch between URI parameters {uri_params} " f"and function parameters {func_params}"
f"Mismatch between URI parameters {uri_params} and function parameters {func_params}"
)
# Register as template

2
src/mcp/server/fastmcp/tools/base.py
View file

@ -27,7 +27,7 @@ class Tool(BaseModel):
description: str = Field(description="Description of what the tool does")
parameters: dict[str, Any] = Field(description="JSON schema for tool parameters")
fn_metadata: FuncMetadata = Field(
description="Metadata about the function including a pydantic model for tool" " arguments"
description="Metadata about the function including a pydantic model for tool arguments"
)
is_async: bool = Field(description="Whether the tool is async")
context_kwarg: str | None = Field(None, description="Name of the kwarg that should receive context")

2
src/mcp/shared/auth.py
View file

@ -87,7 +87,7 @@ class OAuthClientMetadata(BaseModel):
elif len(self.redirect_uris) == 1:
return self.redirect_uris[0]
else:
raise InvalidRedirectUriError("redirect_uri must be specified when client " "has multiple registered URIs")
raise InvalidRedirectUriError("redirect_uri must be specified when client has multiple registered URIs")
class OAuthClientInformationFull(OAuthClientMetadata):

4
src/mcp/shared/session.py
View file

@ -402,7 +402,7 @@ class BaseSession(
except Exception as e:
# For other validation errors, log and continue
logging.warning(
f"Failed to validate notification: {e}. " f"Message was: {message.message.root}"
f"Failed to validate notification: {e}. Message was: {message.message.root}"
)
else: # Response or error
stream = self._response_streams.pop(message.message.root.id, None)
@ -410,7 +410,7 @@ class BaseSession(
await stream.send(message.message.root)
else:
await self._handle_incoming(
RuntimeError("Received response with an unknown " f"request ID: {message}")
RuntimeError(f"Received response with an unknown request ID: {message}")
)
except anyio.ClosedResourceError: