(self, pool)
| 40 | self.dbapi_connections = set() |
| 41 | |
| 42 | def add_pool(self, pool): |
| 43 | event.listen(pool, "checkout", self._add_conn) |
| 44 | event.listen(pool, "checkin", self._remove_conn) |
| 45 | event.listen(pool, "close", self._remove_conn) |
| 46 | event.listen(pool, "close_detached", self._remove_conn) |
| 47 | # note we are keeping "invalidated" here, as those are still |
| 48 | # opened connections we would like to roll back |
| 49 | |
| 50 | def _add_conn(self, dbapi_con, con_record, con_proxy): |
| 51 | self.dbapi_connections.add(dbapi_con) |