equal
deleted
inserted
replaced
745 processed.append(operation) |
745 processed.append(operation) |
746 operation.handle_event('%s_event' % trstate) |
746 operation.handle_event('%s_event' % trstate) |
747 self.pending_operations[:] = processed |
747 self.pending_operations[:] = processed |
748 self.debug('%s session %s done', trstate, self.id) |
748 self.debug('%s session %s done', trstate, self.id) |
749 except: |
749 except: |
750 self.critical('error while %sing', trstate, exc_info=True) |
|
751 # if error on [pre]commit: |
750 # if error on [pre]commit: |
752 # |
751 # |
753 # * set .failed = True on the operation causing the failure |
752 # * set .failed = True on the operation causing the failure |
754 # * call revert<event>_event on processed operations |
753 # * call revert<event>_event on processed operations |
755 # * call rollback_event on *all* operations |
754 # * call rollback_event on *all* operations |