equal
deleted
inserted
replaced
482 operation = self.pending_operations.pop(0) |
482 operation = self.pending_operations.pop(0) |
483 operation.processed = trstate |
483 operation.processed = trstate |
484 try: |
484 try: |
485 operation.handle_event('%s_event' % trstate) |
485 operation.handle_event('%s_event' % trstate) |
486 except: |
486 except: |
487 self.exception('error while %sing', trstate) |
487 self.critical('error while %sing', trstate, |
|
488 exc_info=sys.exc_info()) |
488 self.debug('%s session %s done', trstate, self.id) |
489 self.debug('%s session %s done', trstate, self.id) |
489 finally: |
490 finally: |
490 self._touch() |
491 self._touch() |
491 self.commit_state = None |
492 self.commit_state = None |
492 self.pending_operations[:] = [] |
493 self.pending_operations[:] = [] |