(self, dburi, short_lived_sessions=False, **kwargs)
| 56 | return create_engine(dburi, poolclass=NullPool, **kwargs) |
| 57 | |
| 58 | def create_session(self, dburi, short_lived_sessions=False, **kwargs): |
| 59 | engine = self.get_engine(dburi, **kwargs) |
| 60 | if self.forked: |
| 61 | if short_lived_sessions or dburi not in self._sessions: |
| 62 | self._sessions[dburi] = sessionmaker(bind=engine) |
| 63 | return engine, self._sessions[dburi] |
| 64 | return engine, sessionmaker(bind=engine) |
| 65 | |
| 66 | def invalidate(self, dburi): |
| 67 | """Dispose cached engine/session state for a database URI.""" |