[autofix.ci] apply automated fixes

Author: autofix-ci[bot]

src/backend/base/langflow/api/v1/mcp.py

@@ -58,6 +58,7 @@ async def handle_global_call_tool(name: str, arguments: dict) -> list[types.Text
 sse = SseServerTransport("/api/v1/mcp/")
 streamable_http_manager = StreamableHTTPSessionManager(server)
 
+
 def find_validation_error(exc):
     """Searches for a pydantic.ValidationError in the exception chain."""
     while exc:
@@ -154,7 +155,10 @@ async def _dispatch_streamable_http(
 
     return Response()
 
+
 streamable_http_methods = ["GET", "POST", "DELETE"]
+
+
 @router.api_route("/streamable", methods=streamable_http_methods)
 @router.api_route("/streamable/", methods=streamable_http_methods)
 async def handle_streamable_http(request: Request, current_user: CurrentActiveMCPUser):

src/backend/base/langflow/api/v1/mcp_projects.py

@@ -77,7 +77,6 @@
 )
 
 
-
 async def verify_project_auth(
     db: AsyncSession,
     project_id: UUID,
@@ -212,7 +211,6 @@ def get_project_sse(project_id: UUID | None) -> SseServerTransport:
     return project_sse_transports[project_id_str]
 
 
-
 async def _build_project_tools_response(
     project_id: UUID,
     current_user: CurrentActiveMCPUser,
@@ -337,9 +335,7 @@ async def _dispatch_project_streamable_http(
     except HTTPException:
         raise
     except Exception as exc:
-        await logger.aexception(
-            f"Error handling Streamable HTTP request for project {project_id}: {exc!s}"
-        )
+        await logger.aexception(f"Error handling Streamable HTTP request for project {project_id}: {exc!s}")
         raise HTTPException(status_code=500, detail="Internal server error in project MCP transport") from exc
     finally:
         current_request_variables_ctx.reset(request_vars_token)

src/backend/tests/unit/api/v1/test_mcp.py

@@ -192,6 +192,7 @@ async def test_find_validation_error_with_pydantic_error():
     # Create a pydantic ValidationError by catching it
     validation_error = None
     try:
+
         class TestModel(pydantic.BaseModel):
             required_field: str
 
@@ -226,6 +227,7 @@ async def test_find_validation_error_with_context():
     # Create a pydantic ValidationError by catching it
     validation_error = None
     try:
+
         class TestModel(pydantic.BaseModel):
             required_field: str
 
@@ -263,8 +265,10 @@ async def test_mcp_sse_validation_error_logged():
     # Verify the function exists and works
     validation_error = None
     try:
+
         class TestModel(pydantic.BaseModel):
             required_field: str
+
         TestModel()
     except pydantic.ValidationError as e:
         validation_error = e

src/backend/tests/unit/api/v1/test_mcp_projects.py

@@ -602,6 +602,7 @@ def _prepare_install_test_env(monkeypatch, tmp_path, filename="cursor.json"):
     config_path.parent.mkdir(parents=True, exist_ok=True)
 
     monkeypatch.setattr("langflow.api.v1.mcp_projects.get_client_ip", lambda request: "127.0.0.1")
+
     async def fake_get_config_path(client_name):
         return config_path
 

src/lfx/src/lfx/services/mcp_composer/service.py

@@ -73,7 +73,9 @@ class MCPComposerService(Service):
 
     def __init__(self):
         super().__init__()
-        self.project_composers: dict[str, dict] = {}  # project_id -> {process, host, port, streamable_http_url, auth_config}
+        self.project_composers: dict[
+            str, dict
+        ] = {}  # project_id -> {process, host, port, streamable_http_url, auth_config}
         self._start_locks: dict[
             str, asyncio.Lock
         ] = {}  # Lock to prevent concurrent start operations for the same project
@@ -1045,9 +1047,7 @@ async def _do_start_project_composer(
 
         project_host = auth_config.get("oauth_host") if auth_config else "unknown"
         project_port = auth_config.get("oauth_port") if auth_config else "unknown"
-        await logger.adebug(
-            f"Starting MCP Composer for project {project_id} on {project_host}:{project_port}"
-        )
+        await logger.adebug(f"Starting MCP Composer for project {project_id} on {project_host}:{project_port}")
 
         # Use a per-project lock to prevent race conditions
         if project_id not in self._start_locks: