Created
May 9, 2023 15:45
-
-
Save pc-m/bc442545c248f73a9b46158ffbb46a4f to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/xivo_dao/helpers/db_views.py b/xivo_dao/helpers/db_views.py | |
| index 401f14a9..51c3c002 100644 | |
| --- a/xivo_dao/helpers/db_views.py | |
| +++ b/xivo_dao/helpers/db_views.py | |
| @@ -10,7 +10,7 @@ from sqlalchemy.inspection import inspect | |
| from sqlalchemy.sql.ddl import DDLElement | |
| from sqlalchemy.sql.selectable import Selectable | |
| -from .db_manager import Base, Session, daosession | |
| +from .db_manager import Base, Session | |
| # Adapted from: | |
| @@ -160,9 +160,8 @@ class _MaterializedViewMeta(DeclarativeMeta): | |
| self._view_dependencies_handler = None | |
| self._track_dependencies() | |
| - @daosession | |
| - def refresh(session, self, concurrently=True): | |
| - _refresh_materialized_view(session, self.__table__.fullname, concurrently) | |
| + def refresh(self, concurrently=True): | |
| + _refresh_materialized_view(Session(), self.__table__.fullname, concurrently) | |
| def _track_dependencies(self): | |
| if not hasattr(self, '_view_dependencies'): | |
| @@ -172,7 +171,7 @@ class _MaterializedViewMeta(DeclarativeMeta): | |
| @listens_for(Session, 'before_commit') | |
| def _before_session_commit_handler(session): | |
| - for obj in session: | |
| + for obj in session.dirty | session.new | session.deleted: | |
| if isinstance(obj, tuple(targets)): | |
| self.refresh(concurrently=True) | |
| return |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment