refactor: drop unused logger/logging (#1926)
This commit is contained in:
parent
656f887aff
commit
7b728a243e
6 changed files with 0 additions and 16 deletions
|
|
@ -21,8 +21,6 @@ import click
|
||||||
from mcp import ClientSession
|
from mcp import ClientSession
|
||||||
from mcp.client.streamable_http import streamable_http_client
|
from mcp.client.streamable_http import streamable_http_client
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
async def run_demo(url: str, items: int, checkpoint_every: int) -> None:
|
async def run_demo(url: str, items: int, checkpoint_every: int) -> None:
|
||||||
"""Run the SSE polling demo."""
|
"""Run the SSE polling demo."""
|
||||||
|
|
|
||||||
|
|
@ -8,7 +8,6 @@ This is not a production-ready implementation.
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import logging
|
|
||||||
import secrets
|
import secrets
|
||||||
import time
|
import time
|
||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
@ -29,8 +28,6 @@ from mcp.server.auth.provider import (
|
||||||
)
|
)
|
||||||
from mcp.shared.auth import OAuthClientInformationFull, OAuthToken
|
from mcp.shared.auth import OAuthClientInformationFull, OAuthToken
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class SimpleAuthSettings(BaseSettings):
|
class SimpleAuthSettings(BaseSettings):
|
||||||
"""Simple OAuth settings for demo purposes."""
|
"""Simple OAuth settings for demo purposes."""
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,3 @@
|
||||||
import logging
|
|
||||||
import re
|
import re
|
||||||
from urllib.parse import urljoin, urlparse
|
from urllib.parse import urljoin, urlparse
|
||||||
|
|
||||||
|
|
@ -16,8 +15,6 @@ from mcp.shared.auth import (
|
||||||
)
|
)
|
||||||
from mcp.types import LATEST_PROTOCOL_VERSION
|
from mcp.types import LATEST_PROTOCOL_VERSION
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
def extract_field_from_www_auth(response: Response, field_name: str) -> str | None:
|
def extract_field_from_www_auth(response: Response, field_name: str) -> str | None:
|
||||||
"""Extract field from WWW-Authenticate header.
|
"""Extract field from WWW-Authenticate header.
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,6 @@
|
||||||
|
|
||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
import logging
|
|
||||||
from contextlib import AsyncExitStack
|
from contextlib import AsyncExitStack
|
||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
||||||
|
|
@ -22,8 +21,6 @@ from mcp.server import Server
|
||||||
from mcp.server.fastmcp import FastMCP
|
from mcp.server.fastmcp import FastMCP
|
||||||
from mcp.shared.session import ProgressFnT
|
from mcp.shared.session import ProgressFnT
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class Client:
|
class Client:
|
||||||
"""A high-level MCP client for connecting to MCP servers.
|
"""A high-level MCP client for connecting to MCP servers.
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,3 @@
|
||||||
import logging
|
|
||||||
from contextlib import asynccontextmanager
|
from contextlib import asynccontextmanager
|
||||||
|
|
||||||
import anyio
|
import anyio
|
||||||
|
|
@ -10,8 +9,6 @@ from starlette.websockets import WebSocket
|
||||||
import mcp.types as types
|
import mcp.types as types
|
||||||
from mcp.shared.message import SessionMessage
|
from mcp.shared.message import SessionMessage
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@asynccontextmanager # pragma: no cover
|
@asynccontextmanager # pragma: no cover
|
||||||
async def websocket_server(scope: Scope, receive: Receive, send: Send):
|
async def websocket_server(scope: Scope, receive: Receive, send: Send):
|
||||||
|
|
|
||||||
|
|
@ -1,6 +1,5 @@
|
||||||
"""Tests for StreamableHTTP server DNS rebinding protection."""
|
"""Tests for StreamableHTTP server DNS rebinding protection."""
|
||||||
|
|
||||||
import logging
|
|
||||||
import multiprocessing
|
import multiprocessing
|
||||||
import socket
|
import socket
|
||||||
from collections.abc import AsyncGenerator
|
from collections.abc import AsyncGenerator
|
||||||
|
|
@ -19,7 +18,6 @@ from mcp.server.transport_security import TransportSecuritySettings
|
||||||
from mcp.types import Tool
|
from mcp.types import Tool
|
||||||
from tests.test_helpers import wait_for_server
|
from tests.test_helpers import wait_for_server
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
SERVER_NAME = "test_streamable_http_security_server"
|
SERVER_NAME = "test_streamable_http_security_server"
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue