Changeset 128 for projects/sAsync/trunk
- Timestamp:
- 03/22/08 21:01:32 (8 months ago)
- Files:
-
- projects/sAsync/trunk/sasync/database.py (modified) (3 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
projects/sAsync/trunk/sasync/database.py
r74 r128 29 29 from twisted.python import failure 30 30 import sqlalchemy as SA 31 from sqlalchemy.orm import create_session 32 31 33 from asynqueue import ThreadQueue 32 34 … … 326 328 def getSession(self): 327 329 """ 328 Get a com ittable session object330 Get a commitable session object 329 331 """ 330 332 def gotConnection(connection): 331 d = self.q.call( SA.create_session, bind_to=connection, doNext=True)333 d = self.q.call(create_session, connection, doNext=True) 332 334 d.addCallback(gotSession) 333 335 return d … … 358 360 def _table(): 359 361 if not hasattr(self, '_meta'): 360 self._meta = SA. BoundMetaData(self._engine)362 self._meta = SA.MetaData(self._engine) 361 363 indexes = {} 362 364 for key in kw.keys():
