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
评论列表
文章目录