db.py 文件源码

def close(self):
        current_transactions = tuple()
        if self.transaction is not None:
            current_transactions = self.transaction._iterate_parents()
        try:
            with gevent.Timeout(5):
                super(RoutingSession, self).close()
        # pylint: disable=E0712
        except gevent.Timeout:
            # pylint: enable=E0712
            close_connections(self.engines.itervalues(), current_transactions)
            raise