Linting fixes

Author: madhav165

mcpgateway/cache/session_registry.py

@@ -129,9 +129,6 @@ def __init__(
             database_url: Database connection URL (required for database backend)
             session_ttl: Session time-to-live in seconds
             message_ttl: Message time-to-live in seconds
-
-        Raises:
-            ValueError: If backend is invalid or required URL is missing
         """
         super().__init__(backend=backend, redis_url=redis_url, database_url=database_url, session_ttl=session_ttl, message_ttl=message_ttl)
         self._sessions: Dict[str, Any] = {}  # Local transport cache
@@ -415,6 +412,7 @@ async def respond(
             server_id: Server ID
             session_id: Session ID
             user: User information
+            base_url: Base URL for the FastAPI request
 
         """
 
@@ -681,6 +679,7 @@ async def generate_response(self, message: json, transport: SSETransport, server
             transport: Transport where message should be responded in
             server_id: Server ID
             user: User information
+            base_url: Base URL for the FastAPI request
 
         """
         result = {}

mcpgateway/db.py

@@ -1087,5 +1087,6 @@ def init_db():
     except SQLAlchemyError as e:
         raise Exception(f"Failed to initialize database: {str(e)}")
 
+
 if __name__ == "__main__":
     init_db()

mcpgateway/handlers/sampling.py

@@ -150,9 +150,9 @@ async def _add_context(self, _db: Session, messages: List[Dict[str, Any]], _cont
         """Add context to messages.
 
         Args:
-            db: Database session
+            _db: Database session
             messages: Message list
-            context_type: Context inclusion type
+            _context_type: Context inclusion type
 
         Returns:
             Messages with added context

mcpgateway/services/resource_service.py

@@ -222,9 +222,7 @@ async def list_resources(self, db: Session, include_inactive: bool = False) -> L
             db (Session): The SQLAlchemy database session.
             include_inactive (bool): If True, include inactive resources in the result.
                 Defaults to False.
-            cursor (Optional[str], optional): An opaque cursor token for pagination. Currently,
-                this parameter is ignored. Defaults to None.
-
+            
         Returns:
             List[ResourceRead]: A list of resources represented as ResourceRead objects.
         """
@@ -249,8 +247,6 @@ async def list_server_resources(self, db: Session, server_id: int, include_inact
             server_id (int): Server ID
             include_inactive (bool): If True, include inactive resources in the result.
                 Defaults to False.
-            cursor (Optional[str], optional): An opaque cursor token for pagination. Currently,
-                this parameter is ignored. Defaults to None.
 
         Returns:
             List[ResourceRead]: A list of resources represented as ResourceRead objects.

mcpgateway/services/tool_service.py

@@ -521,6 +521,9 @@ async def invoke_tool(self, db: Session, name: str, arguments: Dict[str, Any]) -
                 async def connect_to_sse_server(server_url: str):
                     """
                     Connect to an MCP server running with SSE transport
+
+                    Args:
+                        server_url (str): MCP Server SSE URL
                     """
                     # Use async with directly to manage the context
                     async with sse_client(url=server_url, headers=headers) as streams:

mcpgateway/transports/sse_transport.py

@@ -126,7 +126,7 @@ async def create_sse_response(self, _request: Request) -> EventSourceResponse:
         """Create SSE response for streaming.
 
         Args:
-            request: FastAPI request
+            _request: FastAPI request
 
         Returns:
             SSE response object
@@ -209,7 +209,7 @@ async def _client_disconnected(self, _request: Request) -> bool:
         """Check if client has disconnected.
 
         Args:
-            request: FastAPI Request object
+            _request: FastAPI Request object
 
         Returns:
             bool: True if client disconnected