equal
deleted
inserted
replaced
231 s._threaddata.pool = self.pool |
231 s._threaddata.pool = self.pool |
232 # register session to ensure it gets closed |
232 # register session to ensure it gets closed |
233 self._dumb_sessions.append(s) |
233 self._dumb_sessions.append(s) |
234 return s |
234 return s |
235 |
235 |
236 def execute(self, rql, args=None, eid_key=None, build_descr=True): |
236 def execute(self, rql, args=None, build_descr=True): |
237 return self.o.execute(self.session, rql, args, eid_key, build_descr) |
237 return self.o.execute(self.session, rql, args, build_descr) |
238 |
238 |
239 def commit(self): |
239 def commit(self): |
240 self.session.commit() |
240 self.session.commit() |
241 self.session.set_pool() |
241 self.session.set_pool() |
242 |
242 |