equal
deleted
inserted
replaced
260 """lightweight session using the current user with hi-jacked groups""" |
260 """lightweight session using the current user with hi-jacked groups""" |
261 # use self.session.user.eid to get correct owned_by relation, unless explicit eid |
261 # use self.session.user.eid to get correct owned_by relation, unless explicit eid |
262 u = self.repo._build_user(self.session, self.session.user.eid) |
262 u = self.repo._build_user(self.session, self.session.user.eid) |
263 u._groups = set(groups) |
263 u._groups = set(groups) |
264 s = Session(u, self.repo) |
264 s = Session(u, self.repo) |
265 s._threaddata.cnxset = self.cnxset |
265 s._tx.cnxset = self.cnxset |
266 s._threaddata.ctx_count = 1 |
266 s._tx.ctx_count = 1 |
267 # register session to ensure it gets closed |
267 # register session to ensure it gets closed |
268 self._dumb_sessions.append(s) |
268 self._dumb_sessions.append(s) |
269 return s |
269 return s |
270 |
270 |
271 def execute(self, rql, args=None, build_descr=True): |
271 def execute(self, rql, args=None, build_descr=True): |
309 if not source.copy_based_source: |
309 if not source.copy_based_source: |
310 self.sources.remove(source) |
310 self.sources.remove(source) |
311 del self.repo.sources_by_uri[source.uri] |
311 del self.repo.sources_by_uri[source.uri] |
312 undo_monkey_patch() |
312 undo_monkey_patch() |
313 for session in self._dumb_sessions: |
313 for session in self._dumb_sessions: |
314 session._threaddata.cnxset = None |
314 session._tx.cnxset = None |
315 session.close() |
315 session.close() |
316 |
316 |
317 def _prepare_plan(self, rql, kwargs=None): |
317 def _prepare_plan(self, rql, kwargs=None): |
318 rqlst = self.o.parse(rql, annotate=True) |
318 rqlst = self.o.parse(rql, annotate=True) |
319 self.o.solutions(self.session, rqlst, kwargs) |
319 self.o.solutions(self.session, rqlst, kwargs) |