equal
deleted
inserted
replaced
564 self.warning("trying to reconnect") |
564 self.warning("trying to reconnect") |
565 cnx.cnxset.reconnect() |
565 cnx.cnxset.reconnect() |
566 cursor = self.doexec(cnx, sql, args) |
566 cursor = self.doexec(cnx, sql, args) |
567 else: |
567 else: |
568 raise |
568 raise |
569 results = self.process_result(cursor, cbs, session=cnx) |
569 results = self.process_result(cursor, cnx, cbs) |
570 assert dbg_results(results) |
570 assert dbg_results(results) |
571 return results |
571 return results |
572 |
572 |
573 @contextmanager |
573 @contextmanager |
574 def _storage_handler(self, entity, event): |
574 def _storage_handler(self, entity, event): |