[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

examples/mcp.py

@@ -46,7 +46,7 @@ def calculate_tool(args):
         result = eval(expression, {"__builtins__": {}}, {})
         return f"{expression} = {result}"
     except Exception as e:
-        return f"Error: {str(e)}"
+        return f"Error: {e!s}"
 
 
 @app.mcp.tool(

integration_tests/base_routes.py

@@ -181,13 +181,12 @@ async def empty_websocket_endpoint(websocket):
 @empty_websocket_endpoint.on_connect
 async def empty_websocket_on_connect(websocket):
     """Test async handler with no return"""
-    pass
 
 
 @empty_websocket_endpoint.on_close
 async def empty_websocket_on_close(websocket):
     """Test async handler with explicit None return"""
-    return None
+    return
 
 
 # ===== Lifecycle handlers =====

integration_tests/conftest.py

@@ -5,14 +5,13 @@
 import socket
 import subprocess
 import time
-from typing import List
 
 import pytest
 
 from integration_tests.helpers.network_helpers import get_network_host
 
 
-def spawn_process(command: List[str]) -> subprocess.Popen:
+def spawn_process(command: list[str]) -> subprocess.Popen:
     if platform.system() == "Windows":
         command[0] = "python"
         process = subprocess.Popen(command, shell=True, creationflags=subprocess.CREATE_NEW_PROCESS_GROUP)

integration_tests/helpers/http_methods_helpers.py

@@ -1,5 +1,3 @@
-from typing import Optional
-
 import requests
 
 BASE_URL = "http://127.0.0.1:8080"
@@ -39,7 +37,7 @@ def get(
 
 def post(
     endpoint: str,
-    data: Optional[dict] = None,
+    data: dict | None = None,
     expected_status_code: int = 200,
     headers: dict = {},
     should_check_response: bool = True,
@@ -135,7 +133,7 @@ def json_patch(
 
 def multipart_post(
     endpoint: str,
-    files: Optional[dict] = None,
+    files: dict | None = None,
     expected_status_code: int = 200,
     should_check_response: bool = True,
 ) -> requests.Response:
@@ -157,7 +155,7 @@ def multipart_post(
 
 def put(
     endpoint: str,
-    data: Optional[dict] = None,
+    data: dict | None = None,
     expected_status_code: int = 200,
     headers: dict = {},
     should_check_response: bool = True,
@@ -180,7 +178,7 @@ def put(
 
 def patch(
     endpoint: str,
-    data: Optional[dict] = None,
+    data: dict | None = None,
     expected_status_code: int = 200,
     headers: dict = {},
     should_check_response: bool = True,
@@ -203,7 +201,7 @@ def patch(
 
 def delete(
     endpoint: str,
-    data: Optional[dict] = None,
+    data: dict | None = None,
     expected_status_code: int = 200,
     headers: dict = {},
     should_check_response: bool = True,
@@ -226,7 +224,7 @@ def delete(
 
 def head(
     endpoint: str,
-    data: Optional[dict] = None,
+    data: dict | None = None,
     expected_status_code: int = 200,
     headers: dict = {},
     should_check_response: bool = True,
@@ -252,7 +250,7 @@ def head(
 def generic_http_helper(
     method: str,
     endpoint: str,
-    data: Optional[dict] = None,
+    data: dict | None = None,
     expected_status_code: int = 200,
     headers: dict = {},
     should_check_response: bool = True,

integration_tests/subroutes/__init__.py

@@ -6,7 +6,7 @@
 
 sub_router = SubRouter(prefix="/sub_router")
 
-__all__ = ["sub_router", "di_subrouter", "static_router", "async_auth_subrouter", "inherited_auth_subrouter"]
+__all__ = ["async_auth_subrouter", "di_subrouter", "inherited_auth_subrouter", "static_router", "sub_router"]
 
 
 @sub_router.websocket("/ws")

integration_tests/test_basic_routes.py

@@ -3,7 +3,6 @@
 # - most common return types
 # - sync and async
 
-from typing import Optional
 
 import pytest
 
@@ -36,8 +35,8 @@
 def test_basic_get(
     route: str,
     expected_text: str,
-    expected_header_key: Optional[str],
-    expected_header_value: Optional[str],
+    expected_header_key: str | None,
+    expected_header_value: str | None,
     session,
 ):
     res = get(route)
@@ -59,7 +58,7 @@ def test_basic_get(
 )
 def test_json_get(route: str, expected_json: dict, session):
     res = get(route)
-    for key in expected_json.keys():
+    for key in expected_json:
         assert key in res.json()
         assert res.json()[key] == expected_json[key]
 
@@ -94,6 +93,6 @@ def test_json_get(route: str, expected_json: dict, session):
 )
 def test_http_request_info_get(route: str, expected_json: dict, session):
     res = get(route)
-    for key in expected_json.keys():
+    for key in expected_json:
         assert key in res.json()
         assert res.json()[key] == expected_json[key]

robyn/__init__.py

@@ -1168,30 +1168,30 @@ def cors_middleware(request):
 
 
 __all__ = [
-    "Robyn",
-    "Request",
-    "Response",
-    "status_codes",
-    "jsonify",
-    "serve_file",
-    "serve_html",
-    "html",
-    "StreamingResponse",
-    "SSEResponse",
-    "SSEMessage",
     "ALLOW_CORS",
-    "SubRouter",
     "AuthenticationHandler",
     "Headers",
-    "WebSocketConnector",
-    "WebSocketAdapter",
-    "WebSocketDisconnect",
     "JsonBody",
     "MCPApp",
-    "TestClient",
-    "RequestMethod",
+    "Request",
     "RequestBody",
+    "RequestMethod",
     "RequestURL",
+    "Response",
+    "Robyn",
+    "SSEMessage",
+    "SSEResponse",
     "Session",
     "SessionManager",
+    "StreamingResponse",
+    "SubRouter",
+    "TestClient",
+    "WebSocketAdapter",
+    "WebSocketConnector",
+    "WebSocketDisconnect",
+    "html",
+    "jsonify",
+    "serve_file",
+    "serve_html",
+    "status_codes",
 ]

robyn/_param_utils.py

@@ -8,7 +8,7 @@
 import inspect
 import logging
 import types
-from typing import Any, Dict, Optional, Set, Tuple, Union, get_args, get_origin
+from typing import Any, Union, get_args, get_origin
 
 _logger = logging.getLogger(__name__)
 
@@ -23,7 +23,7 @@ class QueryParamValidationError(Exception):
     """Raised when a query or path parameter cannot be coerced to the expected type,
     or when a required parameter is missing."""
 
-    def __init__(self, param_name: str, value: Optional[str], expected_type: type, message: Optional[str] = None):
+    def __init__(self, param_name: str, value: str | None, expected_type: type, message: str | None = None):
         self.param_name = param_name
         self.value = value
         self.expected_type = expected_type
@@ -36,7 +36,7 @@ def __init__(self, param_name: str, value: Optional[str], expected_type: type, m
         super().__init__(self.detail)
 
 
-def unwrap_optional(annotation) -> Tuple[Any, bool]:
+def unwrap_optional(annotation) -> tuple[Any, bool]:
     """
     If annotation is Optional[T] (i.e. T | None / Union[T, None]), return (T, True).
     Handles both typing.Union and PEP 604 union syntax (X | Y).
@@ -91,11 +91,11 @@ def coerce_value(value: str, target_type: type, param_name: str):
 
 
 def resolve_individual_params(
-    unresolved_params: Dict[str, inspect.Parameter],
+    unresolved_params: dict[str, inspect.Parameter],
     query_params,
-    path_params: Optional[Dict[str, str]],
-    route_param_names: Set[str],
-) -> Dict[str, Any]:
+    path_params: dict[str, str] | None,
+    route_param_names: set[str],
+) -> dict[str, Any]:
     """
     Resolve handler parameters as individual path or query parameters.
 
@@ -167,7 +167,7 @@ def resolve_individual_params(
     return resolved
 
 
-def parse_route_param_names(endpoint: str) -> Set[str]:
+def parse_route_param_names(endpoint: str) -> set[str]:
     """
     Extract parameter names from a route endpoint pattern.
     e.g. "/users/:id/posts/:post_id" -> {"id", "post_id"}

robyn/ai.py

@@ -66,17 +66,14 @@ class MemoryProvider(ABC):
     @abstractmethod
     async def store(self, user_id: str, data: dict[str, Any]) -> None:
         """Store data in memory"""
-        pass
 
     @abstractmethod
     async def retrieve(self, user_id: str, query: str | None = None) -> list[dict[str, Any]]:
         """Retrieve data from memory"""
-        pass
 
     @abstractmethod
     async def clear(self, user_id: str) -> None:
         """Clear memory for a user"""
-        pass
 
 
 class InMemoryProvider(MemoryProvider):
@@ -132,7 +129,6 @@ class AgentRunner(ABC):
     @abstractmethod
     async def run(self, query: str, **kwargs) -> dict[str, Any]:
         """Execute the agent with the given query"""
-        pass
 
 
 class SimpleRunner(AgentRunner):

robyn/jsonify.py

@@ -1,9 +1,9 @@
-from typing import Any, Dict, List, Union
+from typing import Any
 
 import orjson
 
 
-def jsonify(data: Union[Dict[str, Any], List[Any]]) -> str:
+def jsonify(data: dict[str, Any] | list[Any]) -> str:
     """
     This function serializes input data to a json string