Hotfix

pyproject.toml

@@ -24,7 +24,6 @@ alembic = "^1.12.0"
 aiokafka = "^0.8.1"
 yarl = "^1.9.2"
 pyjwt = "^2.8.0"
-cryptography = "^41.0.4"
 loguru = "^0.7.2"
 websockets = "^11.0.3"
 backoff = "^2.2.1"
@@ -37,6 +36,7 @@ typer = {version = "^0.9.0", extras = ["all"]}
 redis = ">=4.2.0rc1"
 pydantic = {version = "^2.5.1", extras = ["email"]}
 py-fast-grpc = "^0.3.4"
+cryptography = "^41.0.7"
 
 [tool.poetry.extras]
 sqlite = ["aiosqlite"]

sapphire/users/database/service.py

@@ -26,7 +26,7 @@ async def get_user(
             session: AsyncSession,
             user_id: uuid.UUID | Type[Empty] = Empty,
             email: str | Type[Empty] = Empty,
-    ):
+    ) -> User | None:
         filters = []
         if user_id is not Empty:
             filters.append(User.id == user_id)

sapphire/users/internal_api/client/service.py

@@ -1,12 +1,16 @@
 import uuid
 
+import backoff
+from grpc.aio import AioRpcError
+
 from sapphire.users.internal_api.models import GetUserRequest, UserResponse
 from sapphire.users.internal_api.service import UsersGRPCService
 
 from .settings import UsersInternalAPIClientSettings
 
 
 class UsersInternalAPIClient(UsersGRPCService.Client):
+    @backoff.on_exception(backoff.constant, AioRpcError, max_tries=3)
     async def get_user(self, user_id: uuid.UUID) -> UserResponse:
         request = GetUserRequest(id=user_id)
         return await super().get_user(request=request)

sapphire/users/internal_api/models.py

@@ -12,7 +12,7 @@ class UserResponse(BaseModel):
     email: EmailStr
     first_name: str | None = None
     last_name: str | None = None
-    is_activated: bool
+    is_activated: bool = False
 
     about: str | None = None
     main_specialization_id: uuid.UUID | None = None