equal
deleted
inserted
replaced
36 from cubicweb.selectors import objectify_selector |
36 from cubicweb.selectors import objectify_selector |
37 from cubicweb.req import RequestSessionBase |
37 from cubicweb.req import RequestSessionBase |
38 from cubicweb.dbapi import ConnectionProperties |
38 from cubicweb.dbapi import ConnectionProperties |
39 from cubicweb.utils import make_uid, RepeatList |
39 from cubicweb.utils import make_uid, RepeatList |
40 from cubicweb.rqlrewrite import RQLRewriter |
40 from cubicweb.rqlrewrite import RQLRewriter |
|
41 from cubicweb.server import ShuttingDown |
41 from cubicweb.server.edition import EditedEntity |
42 from cubicweb.server.edition import EditedEntity |
42 |
43 |
43 |
44 |
44 ETYPE_PYOBJ_MAP[Binary] = 'Bytes' |
45 ETYPE_PYOBJ_MAP[Binary] = 'Bytes' |
45 |
46 |
1142 @property |
1143 @property |
1143 def pool(self): |
1144 def pool(self): |
1144 """connections pool, set according to transaction mode for each query""" |
1145 """connections pool, set according to transaction mode for each query""" |
1145 if self.repo.shutting_down: |
1146 if self.repo.shutting_down: |
1146 self.reset_pool(True) |
1147 self.reset_pool(True) |
1147 raise Exception('repository is shutting down') |
1148 raise ShuttingDown('repository is shutting down') |
1148 return getattr(self._threaddata, 'pool', None) |
1149 return getattr(self._threaddata, 'pool', None) |
1149 |
1150 |
1150 |
1151 |
1151 class InternalManager(object): |
1152 class InternalManager(object): |
1152 """a manager user with all access rights used internally for task such as |
1153 """a manager user with all access rights used internally for task such as |