warning fixes

Author: HardMax71

backend/app/infrastructure/kafka/events/base.py

@@ -2,7 +2,7 @@
 from typing import Any, ClassVar
 from uuid import uuid4
 
-from pydantic import ConfigDict, Field
+from pydantic import ConfigDict, Field, field_serializer
 from pydantic_avro import AvroBase
 
 from app.domain.enums.events import EventType
@@ -22,11 +22,11 @@ class BaseEvent(AvroBase):
     # Each subclass must define its topic
     topic: ClassVar[KafkaTopic]
 
-    model_config = ConfigDict(
-        json_encoders={
-            datetime: lambda v: v.isoformat()
-        }
-    )
+    model_config = ConfigDict()
+
+    @field_serializer('timestamp')
+    def serialize_timestamp(self, dt: datetime) -> str:
+        return dt.isoformat()
 
     def to_dict(self) -> dict[str, Any]:
         # Use mode='json' to properly serialize datetime objects to ISO strings

backend/app/schemas_pydantic/health_dashboard.py

@@ -1,6 +1,6 @@
 from datetime import datetime
 
-from pydantic import BaseModel, Field
+from pydantic import BaseModel, ConfigDict, Field
 
 from app.domain.enums.health import AlertSeverity
 
@@ -160,8 +160,7 @@ class DependencyEdge(BaseModel):
     to_service: str = Field(..., alias="to")
     critical: bool
 
-    class Config:
-        populate_by_name = True
+    model_config = ConfigDict(populate_by_name=True)
 
 
 class DependencyGraph(BaseModel):

backend/app/schemas_pydantic/user.py

@@ -2,7 +2,6 @@
 from typing import List, Optional
 from uuid import uuid4
 
-from bson import ObjectId
 from pydantic import BaseModel, ConfigDict, EmailStr, Field
 
 from app.domain.enums.user import UserRole
@@ -69,9 +68,6 @@ class UserResponse(UserBase):
 
     model_config = ConfigDict(
         from_attributes=True,
-        json_encoders={
-            ObjectId: str
-        }
     )
 
 
@@ -89,9 +85,6 @@ class User(BaseModel):
     model_config = ConfigDict(
         from_attributes=True,
         arbitrary_types_allowed=True,
-        json_encoders={
-            ObjectId: str
-        }
     )
 
     @classmethod

backend/pyproject.toml

@@ -226,6 +226,5 @@ asyncio_mode = "auto"
 asyncio_default_fixture_loop_scope = "function"
 log_cli = false
 log_cli_level = "ERROR"
-log_capture = true
 log_level = "ERROR"
 addopts = "-n 4 --dist loadfile --tb=short -q --no-header -q"

backend/tests/unit/core/test_logging_and_correlation.py

@@ -1,17 +1,17 @@
+import io
 import json
 import logging
-import io
 from typing import Any
 
 import pytest
+from app.core.correlation import CorrelationContext, CorrelationMiddleware
+from app.core.logging import CorrelationFilter, JSONFormatter, setup_logger
 from starlette.applications import Starlette
 from starlette.requests import Request
 from starlette.responses import JSONResponse
+from starlette.routing import Route
 from starlette.testclient import TestClient
 
-from app.core.correlation import CorrelationContext, CorrelationMiddleware
-from app.core.logging import CorrelationFilter, JSONFormatter, setup_logger
-
 
 def capture_log(formatter: logging.Formatter, msg: str, extra: dict[str, Any] | None = None) -> dict[str, Any]:
     logger = logging.getLogger("t")
@@ -71,12 +71,10 @@ def test_correlation_context_and_filter() -> None:
 
 
 def test_correlation_middleware_sets_header() -> None:
-    app = Starlette()
-
-    @app.route("/ping")
-    async def ping(request: Request):  # type: ignore[override]
+    async def ping(request: Request) -> JSONResponse:
         return JSONResponse({"ok": True})
 
+    app = Starlette(routes=[Route("/ping", ping)])
     app.add_middleware(CorrelationMiddleware)
     with TestClient(app) as client:
         r = client.get("/ping")

backend/tests/unit/schemas_pydantic/test_notification_schemas.py

@@ -1,7 +1,6 @@
 from datetime import UTC, datetime, timedelta
 
 import pytest
-
 from app.domain.enums.notification import NotificationChannel, NotificationSeverity, NotificationStatus
 from app.schemas_pydantic.notification import (
     Notification,
@@ -45,7 +44,7 @@ def test_notification_batch_validation_limits():
         NotificationBatch(notifications=[])
 
     # Upper bound: >1000 should fail
-    many = [n1.copy() for _ in range(1001)]
+    many = [n1.model_copy() for _ in range(1001)]
     with pytest.raises(ValueError):
         NotificationBatch(notifications=many)