equal
deleted
inserted
replaced
472 operation = self.pending_operations.pop(0) |
472 operation = self.pending_operations.pop(0) |
473 operation.processed = trstate |
473 operation.processed = trstate |
474 try: |
474 try: |
475 operation.handle_event('%s_event' % trstate) |
475 operation.handle_event('%s_event' % trstate) |
476 except: |
476 except: |
477 self.exception('error while %sing', trstate) |
477 self.critical('error while %sing', trstate, |
|
478 exc_info=sys.exc_info()) |
478 self.debug('%s session %s done', trstate, self.id) |
479 self.debug('%s session %s done', trstate, self.id) |
479 finally: |
480 finally: |
480 self._touch() |
481 self._touch() |
481 self.commit_state = None |
482 self.commit_state = None |
482 self.pending_operations[:] = [] |
483 self.pending_operations[:] = [] |