From 36a27c0c1905ace7bbc5e8fcef1b8f468451dcb9 Mon Sep 17 00:00:00 2001 From: grossmj Date: Tue, 1 Jun 2021 16:12:06 +0930 Subject: [PATCH] Force refresh of updated_at value for RBAC db models. --- gns3server/db/repositories/rbac.py | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/gns3server/db/repositories/rbac.py b/gns3server/db/repositories/rbac.py index e71a25f0..39d52320 100644 --- a/gns3server/db/repositories/rbac.py +++ b/gns3server/db/repositories/rbac.py @@ -96,12 +96,14 @@ class RbacRepository(BaseRepository): update_values = role_update.dict(exclude_unset=True) query = update(models.Role).\ where(models.Role.role_id == role_id).\ - values(update_values).\ - execution_options(synchronize_session="fetch") + values(update_values) await self._db_session.execute(query) await self._db_session.commit() - return await self.get_role(role_id) + role_db = await self.get_role(role_id) + if role_db: + await self._db_session.refresh(role_db) # force refresh of updated_at value + return role_db async def delete_role(self, role_id: UUID) -> bool: """ @@ -235,12 +237,14 @@ class RbacRepository(BaseRepository): update_values = permission_update.dict(exclude_unset=True) query = update(models.Permission).\ where(models.Permission.permission_id == permission_id).\ - values(update_values).\ - execution_options(synchronize_session="fetch") + values(update_values) await self._db_session.execute(query) await self._db_session.commit() - return await self.get_permission(permission_id) + permission_db = await self.get_permission(permission_id) + if permission_db: + await self._db_session.refresh(permission_db) # force refresh of updated_at value + return permission_db async def delete_permission(self, permission_id: UUID) -> bool: """