equal
deleted
inserted
replaced
194 while not self._queue.empty(): |
194 while not self._queue.empty(): |
195 cnxset = self._queue.get_nowait() |
195 cnxset = self._queue.get_nowait() |
196 |
196 |
197 try: |
197 try: |
198 cnxset.close(True) |
198 cnxset.close(True) |
199 except Exception: |
199 except Exception as e: |
200 self.exception('error while closing %s' % cnxset) |
200 self.exception('error while closing %s, error: %s' % (cnxset, e)) |
201 |
201 |
202 |
202 |
203 class Repository(object): |
203 class Repository(object): |
204 """a repository provides access to a set of persistent storages for |
204 """a repository provides access to a set of persistent storages for |
205 entities and relations |
205 entities and relations |