Skip to content

Commit 4b037df

Browse files
committed
fixes
1 parent 4e07df6 commit 4b037df

File tree

1 file changed

+6
-5
lines changed
  • services/director-v2/src/simcore_service_director_v2/modules/db/repositories

1 file changed

+6
-5
lines changed

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/users.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,12 @@
77

88

99
class UsersRepository(BaseRepository):
10+
def _repo(self):
11+
return UsersRepo(self.db_engine)
12+
1013
async def get_user_email(self, user_id: UserID) -> EmailStr:
11-
async with self.db_engine.connect() as conn:
12-
email = await UsersRepo.get_email(conn, user_id)
13-
return TypeAdapter(EmailStr).validate_python(email)
14+
email = await self._repo().get_email(user_id=user_id)
15+
return TypeAdapter(EmailStr).validate_python(email)
1416

1517
async def get_user_role(self, user_id: UserID) -> UserRole:
16-
async with self.db_engine.connect() as conn:
17-
return await UsersRepo().get_role(conn, user_id=user_id)
18+
return await self._repo().get_role(user_id=user_id)

0 commit comments

Comments
 (0)